Kafka常用命令汇总:

1、列出集群里的所有主题。

kafka-topics.sh --zookeeper localhost:2181 --list

2、 创建一个叫作topic_01的主题,主题包含8分区,每个分区拥有两个副本。

kafka-topics.sh --zookeeper localhost:2181 --create --topic topic_01 --replication-factor 3 --partitions 3

3、列出集群里所有主题的详细信息。

kafka-topics.sh --zookeeper localhost:2181 --describe

4、列出集群里特定主题的详细信息。

kafka-topics.sh --zookeeper localhost:2181 --describe  --topic topic_01

5、删除topic_01的主题。

kafka-topics.sh --zookeeper localhost:2181 --delete  --topic topic_01

6、列出旧版本的所有消费者群组。

kafka-consumer-groups.sh --zookeeper localhost:2181 --list

7、列出新版本的所有消费者群组。

kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.50.162:9092 --list

8、获取旧版本消费者群组testgroup的详细信息。

kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group testgroup

9、获取新版本消费者群组testgroup的详细信息。

kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.50.162:9092 --describe --group testgroup

10、查看某一个topic对应的消息数量。

kafka-run-class.sh  kafka.tools.GetOffsetShell --broker-list 172.21.50.162:9092 --topic topic_01 --time -1

11、查看log日志片段的内容,显示查看日志的内容。

kafka-run-class.sh kafka.tools.DumpLogSegments --files 00000000000000000000.log --print-data-log

12、控制台生产者:向主题 my-topic 生成两个消息。

kafka-console-producer.sh --broker-list localhost:9092 --topic topic_01

13、控制台消费者:从主题 my-topic 获取消息。

kafka-console-consumer.sh --zookeeper localhost:2181  --topic topic_01 --from-beginning

kafka-console-consumer.sh --new-consumer --bootstrap-server 172.21.50.162:9092  --topic topic_01 --from-beginning