# 调测Kafka Producer样例程序
#### 前提条件
- 如需在Windows调测程序，需要配置Windows通过EIP访问集群Kafka，详情请参见[配置Windows通过EIP访问安全模式集群Kafka](https://support.huaweicloud.com/devg3-mrs/mrs_07_130038.html)。
- 如需在Linux调测程序，需要确保当前用户对"src/main/resources"目录下和依赖库文件目录下的所有文件，均具有可读权限。同时保证已安装JDK并已设置java相关环境变量。
 
 #### 在Windows中调测程序
1. 确保本地的hosts文件中配置了远程集群所有主机的主机名和业务IP映射关系。
2. 通过IntelliJ IDEA可直接运行Producer.java，如[图1]所示：
   
   图1运行Producer.java   
   ![](https://support.huaweicloud.com/devg3-mrs/zh-cn_image_0000001620238525.png)
   
   
3. 运行后弹出控制台窗口，可以查看到Producer正在向默认Topic（example-metric1）发送消息，每发送10条，打印一条日志。 
   图2Producer运行窗口   
   ![](https://support.huaweicloud.com/devg3-mrs/zh-cn_image_0000001569639902.png)
   
   
 
 #### 在Linux调测程序
1. 在IntelliJ IDEA中，在生成jar包之前配置工程的"Artifacts"信息。 
   1. 打开IntelliJ IDEA，选择"File \> Project Structures..."进入"Project Structure"页面。
   
   2. 在"Project Structure"页面，选择"Artifacts"，单击"+"并选择"JAR \> Empty"。
      图3添加Artifacts   
      ![](https://support.huaweicloud.com/devg3-mrs/zh-cn_image_0000001569958814.png) 
   
   3. 根据实际情况设置jar包的名称、类型以及输出路径。
      图4设置基本信息   
      ![](https://support.huaweicloud.com/devg3-mrs/zh-cn_image_0000001570118758.png) 
   
   4. 选中"'kafka-examples' compile output"，右键选择"Put into Output Root"。然后单击"Apply"。
      图5Put into Output Root   
      ![](https://support.huaweicloud.com/devg3-mrs/zh-cn_image_0000001620438965.png) 
   
   5. 最后单击"OK"完成配置。
   
   
   
   
2. 生成jar包。 
   1. 打开IntelliJ IDEA，选择"Build \> Build Artifacts..."。
      图6Build Artifacts   
      ![](https://support.huaweicloud.com/devg3-mrs/zh-cn_image_0000001620358509.png) 
   
   2. 在弹出的菜单中，选择"kafka-example:jar \> Build"开始生成jar包。
      图7Build   
      ![](https://support.huaweicloud.com/devg3-mrs/zh-cn_image_0000001569799242.png) 
   
   3. 当Event log中出现如下类似日志时，表示Jar包生成成功。您可以在[1.c]中配置的路径下获取到jar包。
      ```
      14:37 Compilation completed successfully in 25 s 991 ms
      ```
      
   
   
   
   
3. 将工程编译生成的jar包复制到"/opt/client/lib"目录下。 
   图8文件位置   
   ![](https://support.huaweicloud.com/devg3-mrs/zh-cn_image_0000001620118897.png)
   
   
4. 将IntelliJ IDEA工程"src/main/resources"目录下的所有文件复制到与依赖库文件夹同级的目录"src/main/resources"下，即"/opt/client/src/main/resources"。"/opt/client"为客户端安装路径，具体以实际为准。
5. 进入目录"/opt/client"，执行如下命令，运行样例工程。 
   **java -cp /opt/client/lib/\*:/opt/client/src/main/resources** **com.huawei.bigdata.kafka.example.** **Producer**