
# 调测Kafka Consumer样例程序
#### 前提条件
- 如需在Windows调测程序，需要配置Windows通过EIP访问集群Kafka，详情请参见[配置Windows通过EIP访问集群Kafka](https://support.huaweicloud.com/devg-lts-mrs/mrs_07_130038.html)。
- 如需在Linux调测程序，需要确保当前用户对"src/main/resources"目录下和依赖库文件目录下的所有文件，均具有可读权限。同时保证已安装Jdk并已设置java相关环境变量。
 
#### 在Windows中调测程序
1. 确保本地的hosts文件中配置了远程集群所有主机的主机名和业务IP映射关系。
2. 通过IntelliJ IDEA可直接运行Consumer.java，如[图1]所示：
   
   图1运行Consumer.java   
   ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001731877793.png "点击放大")
   
   
3. 单击运行后弹出控制台窗口，可以看到Consumer启动成功后，再启动Producer，即可看到实时接收消息： 
   图2Consumer.java运行窗口   
   ![](https://support.huaweicloud.com/devg-lts-mrs/zh-cn_image_0000001731917693.png "点击放大")
   
   
 
#### 在Linux调测程序
1. 编译并生成Jar包，并将Jar包复制到与依赖库文件夹同级的目录"src/main/resources"下，具体步骤请参考[在Linux调测程序](https://support.huaweicloud.com/devg-lts-mrs/mrs_07_130023.html#mrs_07_130023__section18596249131620)。
2. 运行Consumer样例工程的命令如下。 
   **java -cp /opt/client/lib/\*:/opt/client/src/main/resources** **com.huawei.bigdata.kafka.example.** **Consumer**
   
   
 
