KAFKA基础操作命令_kafka命令 查看group topic

1、查看所有的话题 topic

kafka-topics.sh   --zookeeper 10.10.6.98:2181/kafka --list
1

2、删除 topic

kafka-topics.sh --zookeeper 10.10.6.99:2181/kafka --delete --topic message
1

3、创建topic

 kafka-topics.sh --create --zookeeper 10.10.6.96:2181/kafka --replication-factor 3 --partitions 20  --topic IMS20221160
1

4、查看topic信息

kafka-topics.sh  --describe --zookeeper 10.10.6.98:2181/kafka --topic message
1

5、消费者消费数据

kafka-console-consumer.sh --zookeeper 10.10.6.98:2181/kafka --topic message
1

6、发送消息

kafka-console-producer.sh --broker-list 10.10.6.98:9092 --topic message 
1

7、查看分区的数据

 kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 10.10.6.98:9092 --topic IMS20211126  --time -1
1

8、查看 消费者 组列表

 kafka-consumer-groups.sh --new-consumer  --bootstrap-server 10.10.6.96:9092,10.10.6.98:9092,10.10.6.99:9092 --list
1

9、查看 消费者组 的消费信息

kafka-consumer-groups.sh --new-consumer --describe --bootstrap-server 10.10.6.99:9092 --group NCS_TEST_01
1

kafka-consumer-offset-checker.sh  --zookeeper 10.10.6.98:2181/kafka --topic SCIMS20211214 --group NCS_TEST_98
1

10、查询group的信息

[root@itapp240 kafka_2.11-1.1.1]#   kafka-consumer-groups.sh --zookeeper 10.10.6.98:2181/kafka --list
1

查看kafka 的 topic

kafka-topics.sh --zookeeper 10.10.6.96:2181,10.10.6.98:2181,10.10.6.99:2181/kafka --list | awk {print} | grep 2022112
1