1.查看 Topic 列表
bin/kafka-topics.sh --list --bootstrap-server node1:9092,node2:9092,node3:9092
2.查看指定 Topic 明细
bin/kafka-topics.sh --describe --bootstrap-server node1:9092,node2:9092,node3:9092 --topic topicName
3.创建 Topic
bin/kafka-topics.sh --create --bootstrap-server node1:9092,node2:9092,node3:9092 --topic topicName --partitions 3 --replication-factor 2
4.删除 Topic
bin/kafka-topics.sh --delete --bootstrap-server node1:9092,node2:9092,node3:9092 --topic topicName
5.增加Topic分区数
bin/kafka-topics.sh --alter --bootstrap-server node1:9092,node2:9092,node3:9092 --topic topicName --partitions 3
注意：这个命令不能减少partition数量，只能增加partition数量；也不能用来修改副本个数，如果修改副本数需要使用 kafka-reassign-partitions.sh脚本
6.查看Topic的消费情况
查看所有组的消费情况
kafka-consumer-groups.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --describe --all-groups
查看某一个group的消费情况
bin/kafka-consumer-groups.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --describe --group groupName
上面这个命令在查询kafka数据消费是否有积压时非常有用。可以参考我们另一篇线上消费慢问题的文章。
|