Kafka查看topic、consumergroup状态命令
1，查看kafka topic列表，使⽤--list参数
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
__consumer_offsets
test_topic
test
2，查看kafka特定topic的详情，使⽤--topic与--describe参数
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic lx_test_topic --describe
Topic:test_topic    PartitionCount:1        ReplicationFactor:1    Configs:
Topic: test_topic    Partition: 0    Leader: 0      Replicas: 0    Isr: 0
列出了test_topic的parition数量、replica因⼦以及每个partition的leader、replica信息
3，查看consumer group列表，使⽤--list参数
查看consumer group列表有新、旧两种命令，分别查看新版(信息保存在broker中)consumer列表和⽼版(信息保存在zookeeper中)consumer 列表，因⽽需要区分指定bootstrap--server和zookeeper参数：
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --list
test
bin/kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --list
kafka命令console-consumer-86532
console-consumer-14251
4，查看特定consumer group 详情，使⽤--group与--describe参数
同样根据新/旧版本的consumer，分别指定bootstrap-server与zookeeper参数:
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --group  test --describe
GROUP                          TOPIC          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET    LAG                OWNER
test                        test_topic            0          465            465              0              kafka-python-1.3.1_/127.0.0.1
LOG-END-OFFSET 未增加，说明没有数据⽣成进⼊到kafka，反之
CURRENT-OFFSET的值等于LOG-END-OFFSET，则说明进⼊kafka的数据已经被消费掉了
bin/kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --group console-consumer-14251 --describe
GROUP                          TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG            OWNER
Could not fetch offset from zookeeper for group console-consumer-14251 partition [test_topic,0] due to missing offset data in zookeeper.
console-consumer-14251        test_topic            0          unknown        465            unknown        console-consumer-14251-1513787888172-d3a91f05-0
其中依次展⽰group名称、消费的topic名称、partition id、consumer group最后⼀次提交的offset、最后提交的⽣产消息offset、消费offset与⽣产offset之间的差值、当前消费topic-partition的group成员id(不⼀定包含hostname)
上⾯⽰例中console-consumer-14251是为了测试临时起的⼀个console consumer，缺少在zookeeper中保存的current_offset信息。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。