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