kafka常用命令有哪些呢

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

成都创新互联是一家网站设计公司，集创意、互联网应用、软件技术为一体的创意网站建设服务商，主营产品：成都响应式网站建设公司、高端网站设计、成都营销网站建设。我们专注企业品牌在网站中的整体树立，网络互动的体验，以及在手机等移动端的优质呈现。成都网站建设、做网站、移动互联产品、网络运营、VI设计、云产品.运维为核心业务。为用户提供一站式解决方案，我们深知市场的竞争激烈，认真对待每位客户，为客户提供赏析悦目的作品，网站的价值服务。

  ./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

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