更新时间:2024-06-27 GMT+08:00
分享

调测Kafka Consumer样例程序

前提条件

  • 如需在Windows调测程序,需要配置Windows通过EIP访问集群Kafka,详情请参见配置Windows通过EIP访问普通模式集群Kafka
  • 如需在Linux调测程序,需要确保当前用户对“src/main/resources”目录下和依赖库文件目录下的所有文件,均具有可读权限。同时保证已安装Jdk并已设置java相关环境变量。

在Windows中调测程序

  1. 确保本地的hosts文件中配置了远程集群所有主机的主机名和业务IP映射关系。
  2. 通过IntelliJ IDEA可直接运行Consumer.java,如图1所示:

    图1 运行Consumer.java

  3. 单击运行后弹出控制台窗口,可以看到Consumer启动成功后,再启动Producer,即可看到实时接收消息:

    图2 Consumer.java运行窗口

在Linux调测程序

  1. 编译并生成Jar包,并将Jar包复制到与依赖库文件夹同级的目录“src/main/resources”下,具体步骤请参考在Linux调测程序
  2. 运行Consumer样例工程的命令如下。

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

相关文档