# kafka 安装目录
cd /usr/local/kafka
# 查看kafka topic列表，使用--list参数
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
# 查看kafka特定topic的详情，使用--topic与--describe参数
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic lx_test_topic --describe
# 查看正在运行的消费组
bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list --new-consumer
# 查看 topic 的内容
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic k8s-test-nengguan-mynginx-2022.02.11 --from-beginning
# 查看消息组 ibaboss_mobile 消息堆积情况
bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group ibaboss_mobile
# 删除 topic
kafka-topics.sh --delete --topic k8s-pre-nengguan-self-control-strategy-2022.01.22 --zookeeper zookeeper-0.zookeeper-hs:2181,zookeeper-1.zookeeper-hs:2181,zookeeper-2.zookeeper-hs:2181
相关文章：