调测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