Kafka的几个命令

在《ELK安装以及配置》一文中，有介绍kafka的安装，此文记录几个kafka命令

查看集群描述

bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181

Topic列表查询

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

消费者列表查询

bin/kafka-consumer-groups.sh --bootstrap-server node1:9092 --list

显示某个消费组的消费详情

bin/kafka-consumer-groups.sh --bootstrap-server node1:9092 --describe --group test-consumer-group

删除Topic

[root@test-1 kafka_2.12-2.3.0]# bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic test1
Topic logs.lottery-service is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.
## 这条命令其实并不执行删除动作，仅仅是在zookeeper上标记该topic要被删除而已
## 同时也提醒用户一定要提前打开delete.topic.enable开关，否则删除动作是不会执行的

生产者

bin/kafka-console-producer.sh --broker-list node1:9092 --topic test

消费者

bin/kafka-console-consumer.sh --bootstrap-server node1:9092 --topic test