调测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. 在IntelliJ IDEA中，在生成jar包之前配置工程的“Artifacts”信息。
   1. 打开IntelliJ IDEA，选择“File > Project Structures...”进入“Project Structure”页面。
   2. 在“Project Structure”页面，选择“Artifacts”，单击“+”并选择“JAR > Empty”。
      图3 添加Artifacts
      
   3. 根据实际情况设置jar包的名称、类型以及输出路径。
      图4 设置基本信息
      
   4. 选中“'kafka-examples' compile output”，右键选择“Put into Output Root”。然后单击“Apply”。
      图5 Put into Output Root
      
   5. 最后单击“OK”完成配置。

2. 生成jar包。
   1. 打开IntelliJ IDEA，选择“Build > Build Artifacts...”。
      图6 Build Artifacts
      
   2. 在弹出的菜单中，选择“kafka-example:jar > Build”开始生成jar包。
      图7 Build
      
   3. 当Event log中出现如下类似日志时，表示Jar包生成成功。您可以在1.c中配置的路径下获取到jar包。

      14:37 Compilation completed successfully in 25 s 991 ms

3. 将工程编译生成的jar包复制到“/opt/client/lib”目录下。
   图8 文件位置
   

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