kafka消费主题和消费组总结

1、查询kafka主题列表的命令

// 切换到kafka的安装目录bin目录下,执行如下代码
./kafka-topics.sh --list zookeeper zookeeprerIp:zookeeperPort
// 比如:
./kafka-topics.sh --list zookeeper 127.0.0.1:2181

2、查询kafka主题组消息数据情况

// 切换到kafka的安装目录bin目录下
./kafka-consumer-groups.sh --bootstrap-server kafkaIp:kafkaPort --group groupName --describe
// 比如
./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group test_topic--describe

--describe  显示详细信息

--bootstrap-server 指定kafka连接地址

--group 指定组(对应着yup-site.xml配置文件的kafka.group配置项)

输出结果：

指定自己的分组 自己消费的topic会显示kafka总共有多少数据，以及已经被消费了多少条

标记解释：

TOPIC                                 topic名字
PARTITION                        分区id
CURRENT-OFFSET          当前已消费的条数
LOG-END-OFFSET            总条数
LAG                                     未消费的条数
CONSUMER-ID                   消费id
HOST                                   主机ip
CLIENT-ID                            客户端id