文档首页/ MapReduce服务 MRS/ 开发指南（LTS版）/ Kafka开发指南（安全模式）/ 调测Kafka应用/ 调测Kafka Producer样例程序
更新时间：2024-07-27 GMT+08:00
查看PDF
分享

调测Kafka Producer样例程序

前提条件

  • 已配置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包

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

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

父主题： 调测Kafka应用

相关文档