Kafka - Topic 消费状态常用命令-Toy模板网

这篇具有很好参考价值的文章主要介绍了Kafka - Topic 消费状态常用命令。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

新建 Topic

./kafka-topics --zookeeper 166.188.xx.xx --create --topic flink_source --partitions 1 --replication-factor 1

Kafka - Topic 消费状态常用命令,# MQ,kafka,分布式,topic,group,消费者,生产者,列表

replication-factor：指定副本数量
partitions：指定分区

删除 Topic

./kafka-topics --zookeeper 166.188.xx.xx --delete --topic flink_source

Kafka - Topic 消费状态常用命令,# MQ,kafka,分布式,topic,group,消费者,生产者,列表

查看所有 Topic

./kafka-topics --zookeeper 166.188.xx.xx --list

Kafka - Topic 消费状态常用命令,# MQ,kafka,分布式,topic,group,消费者,生产者,列表

查看指定 Topic 详情

./kafka-topics --zookeeper 166.188.xx.xx --topic flink_source --describe

Kafka - Topic 消费状态常用命令,# MQ,kafka,分布式,topic,group,消费者,生产者,列表

查看 consumer group 列表

查看consumer group列表有新、旧两种命令，分别查看新版（信息保存在broker中）consumer列表和老版（信息保存在zookeeper中）consumer列表，因而需要区分指定bootstrap--server和zookeeper参数

./kafka-consumer-groups --new-consumer --bootstrap-server 166.188.xx.xx:9092 --list

Kafka - Topic 消费状态常用命令,# MQ,kafka,分布式,topic,group,消费者,生产者,列表

./kafka-consumer-groups --zookeeper 166.188.20.32:2181 --list

Kafka - Topic 消费状态常用命令,# MQ,kafka,分布式,topic,group,消费者,生产者,列表

查看指定 consumer group 详情

./kafka-consumer-groups --new-consumer --bootstrap-server 166.188.xx.xx:9092 --group logstash --describe

Kafka - Topic 消费状态常用命令,# MQ,kafka,分布式,topic,group,消费者,生产者,列表

./kafka-consumer-groups --zookeeper 166.188.xx.xx:2181 --group console-consumer-12278 --describe

Kafka - Topic 消费状态常用命令,# MQ,kafka,分布式,topic,group,消费者,生产者,列表

这里同样需要根据新、旧版本的consumer，分别指定bootstrap-server与zookeeper参数。其中依次展示group名称、消费的topic名称、partition id、consumer group最后一次提交的offset、最后提交的生产消息offset、消费offset与生产offset之间的差值、当前消费topic-partition的group成员id（不一定包含hostname）