kafka常用命令有哪些呢

kafka常用命令有哪些呢，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

./kafka-topics.sh --help //帮助文档

1 ./kafka-topics.sh --list --zookeeper ambari1:2181,ambari2:2181 //查看 kafka主题列表

2 ./kafka-topics.sh --describe --zookeeper ambari1:2181,ambari2:2181 //查看 kafka所有主题详细信息

3 ./kafka-topics.sh --describe --zookeeper ambari1:2181,ambari2:2181 --topic test //查看 kafka某一指定主题的详细信息

4 ./kafka-topics.sh --delete --zookeeper ambari1:2181,ambari2:2181 --topic test //删除某一主题

5 ./kafka-topics.sh --zookeeper ambari1:2181,ambari2:2181 --create --topic test --replication-factor 3 --partitions 2 //创建一个叫test的话题，有两个分区，每个分区3个副本

6 测试kafka发送和接收消息（启动两个终端）

#发送消息（注意端口号为配置文件里面的端口号）

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

#消费消息（可能端口号与配置文件保持一致，或与发送端口保持一致）

./kafka-console-consumer.sh --bootstrap-server ambari1:9092 --topic test --from-beginning #加了--from-beginning 重头消费所有的消息

./kafka-console-consumer.sh --bootstrap-server ambari1:9092 --topic test #不加--from-beginning 从最新的一条消息开始消费

./kafka-console-consumer.sh --bootstrap-server ambari1:9092 --topic test --group consumerGroup1 #指定消费者组

7 查看某个topic对应的消息数量

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1

8 显示所有消费者

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

9 获取正在消费的topic（console-consumer-63307）的group的offset

./kafka-consumer-groups.sh --describe --group console-consumer-63307 --bootstrap-server localhost:9092

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注行业资讯频道，感谢您对的支持。