Kafka客户端

李晓波

使用Kafka客户端

使用Kafka工具可以

• 查看消息队列消息内容
  

• 查询消费者消费情况
  

1. 安装

推荐 Offset Explorer 2.1 最新版本：http://www.kafkatool.com/download.html

2.配置

在装有Kafka Tool的Windows机器上打开C:\Windows\System32\drivers\etc\hosts文件，将装有kafka的hive节点的IP和机器名配置上，以标准3节点为例：

172.16.168.201 hivenode01

172.16.168.202 hivenode02

172.16.168.203 hivenode03

3.使用

打开Offset Explorer，点击左上角Add new cluster，配置连接信息，如图：

Cluster name：随意填写
Kafka Cluster Version：
查看Kafka版本，任意hive节点执行：docker ps -a |grep kafka
如果kafka版本为1.0.x，选择0.10
如果kafka版本为2.11.0，选择0.9
Zookeeper Host：当前环境VIP
Zookeeper Port：默认2181

配置好后点击右下角Add，连接Kafka

4.查看队列消息

以查看MPCNotifyMQ队列的最新消息为例：

展开Topic，找到MPCNotifyMQ队列，将右边的Key和Message修改为String，并点击Update，如图：

展开MPCNotifyMQ，选择Partition 0，切换到Data标签，最右边选择Newest，点击RetrieveMessage，如图：

结果中的Message则为消息内容，可以根据里面的time等字段判断最新hive发送到队列内容的时间等

5.查看消费者情况

每个队列对应的消费者（Consumer）一般是以队列名开头的，这里以消费者CachedInterFaceQuene为例：

展开Cunsumers，找到CachedInterFaceQuene，选择Offsets标签，Topic参数代表当前消费者消费的是哪个队列的消息，Lag参数代表剩余未消费数量，如果数量较大证明消费者未正常工作，如图：