在Linux环境中调测Kafka应用

操作场景

在程序代码完成开发后，可以在Linux环境中运行IoTDB-Kafka样例程序。

前提条件

• 已安装IoTDB和Kafka客户端。
• 当客户端所在主机不是集群中的节点时，需要在客户端所在节点的hosts文件中设置主机名和IP地址映射。主机名和IP地址请保持一一对应。

操作步骤

1. 导出Jar包。

   构建Jar包方式有以下两种：

   • 方法一：

     选择“Maven > 样例工程名称 > Lifecycle > clean”，双击“clean”运行maven的clean命令。

     选择“Maven > 样例工程名称 > Lifecycle > install”，双击“install”运行maven的install命令。

     图1 maven工具clean和install
     
   • 方法二：在IDEA的下方Terminal窗口进入“pom.xml”所在目录，手动输入mvn clean install命令进行编译。
     图2 idea terminal输入“mvn clean install”
     

     编译完成，打印“BUILD SUCCESS”，生成target目录，生成Jar包在target目录中。

2. 准备依赖的Jar包。
   1. 进入客户端安装目录，新建“lib”目录并将1生成的Jar包导入到该“lib”目录下，如 “/opt/client/lib”
   2. 进入Kafka客户端，将样例中Kafka依赖的Jar包复制到步骤2.a的lib目录下，例如：

      cp /opt/client/Kafka/kafka/libs/*.jar /opt/client/lib

   3. 进入IoTDB客户端，将样例中IoTDB依赖的Jar包复制到步骤2.a的lib目录下，例如：

      cp /opt/client/IoTDB/iotdb/lib/*.jar /opt/client/lib

   4. 将IntelliJ IDEA工程“src/main/resources”目录下的所有文件复制到与依赖库文件夹同级的目录“src/main/resources”下，即“/opt/client/src/main/resources”。

3. 进入目录“/opt/client”，首先确保“src/main/resources”目录下和依赖库文件目录下的所有文件，对当前用户均具有可读权限。同时保证已安装jdk并已设置Java相关环境变量，然后执行命令，运行样例工程，例如：

   java -cp /opt/client/lib/*:/opt/client/src/main/resources com.huawei.bigdata.iotdb.KafkaConsumerMultThread

查看调测结果

运行结果会有如下成功信息：