# 调测Kafka Producer样例程序
#### 前提条件
- 如需在Windows调测程序，需要配置Windows通过EIP访问集群Kafka，详情请参见[配置Windows通过EIP访问集群Kafka](https://support.huaweicloud.com/devg-lts-mrs/mrs_07_340031.html)。
- 如需在Linux调测程序，需要确保当前用户对"src/main/resources"目录下和依赖库文件目录下的所有文件，均具有可读权限。同时保证已安装JDK并已设置java相关环境变量。
 
 #### 在Windows中调测程序
1. 确保本地的hosts文件中配置了远程集群所有主机的主机名和业务IP映射关系。
2. 通过IntelliJ IDEA可直接运行Producer.java，如[图1]所示：
   
   图1运行Producer.java   
   ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001684093384.png "点击放大")
   
   
3. 运行后弹出控制台窗口，可以查看到Producer正在向默认Topic（example-metric1）发送消息，每发送10条，打印一条日志。 
   图2Producer运行窗口   
   ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001684093658.png "点击放大")
   
   
 
 #### 在Linux调测程序
1. 导出jar包。 
   构建jar包方式有以下两种：
   - 方法一： 选择"Maven \> *样例工程名称* \> Lifecycle \> clean"，双击"clean"运行maven的clean命令。
     选择"Maven \> *样例工程名称* \> Lifecycle \> install"，双击"install"运行maven的install命令。
     图3maven工具clean和install   
     ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001732012505.png "点击放大") 
   
   - 方法二：在IDEA的下方Terminal窗口进入"pom.xml"所在目录，手动输入**mvn clean install** 命令进行编译
     图4idea termial输入"mvn clean install"   
     ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001732092589.png "点击放大")
     编译完成，打印"Build Success"，生成target目录，生成jar包在target目录中。
     图5编译完成，生成jar包   
     ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001684093388.png "点击放大") 
   
   
   
   

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**