更新时间:2024-05-28 GMT+08:00

调测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”。
  5. 进入拷贝目录“/opt/client”,执行如下命令,运行样例工程。

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