调测Kafka Producer样例程序

前提条件

• 如需在Windows调测程序，需要配置Windows通过EIP访问集群Kafka，详情请参见配置Windows通过EIP访问普通模式集群Kafka。
• 如需在Linux调测程序，需要确保当前用户对“src/main/resources”目录下和依赖库文件目录下的所有文件，均具有可读权限。同时保证已安装JDK并已设置java相关环境变量。

在Windows中调测程序

1. 确保本地的hosts文件中配置了远程集群所有主机的主机名和业务IP映射关系。
2. 通过IntelliJ IDEA可直接运行Producer.java，如图1所示：
   图1 运行Producer.java
   

3. 运行后弹出控制台窗口，可以查看到Producer正在向默认Topic（example-metric1）发送消息，每发送10条，打印一条日志。
   图2 Producer运行窗口
   

在Linux调测程序

1. 导出jar包。

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

   • 方法一：

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

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

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

     编译完成，打印“Build Success”，生成target目录，生成jar包在target目录中。

     图5 编译完成，生成jar包
     

2. 将工程编译生成的jar包复制到“/opt/client/lib”目录下。
3. 将IntelliJ IDEA工程“src/main/resources”目录下的所有文件复制到与依赖库文件夹同级的目录“src/main/resources”下，即“/opt/client/src/main/resources”。“/opt/client”为客户端安装路径，具体以实际为准。
4. 进入目录“/opt/client”，首先确保“src/main/resources”目录下和依赖库文件目录下的所有文件，对当前用户均具有可读权限。同时保证已安装JDK并已设置java相关环境变量，然后执行命令运行样例工程，例如：

   java -cp /opt/client/lib/*:/opt/client/src/main/resources com.huawei.bigdata.kafka.example.Producer