这篇文章主要介绍kafka常用命令有哪些,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!

Kafka是一个分布式、分区的、多副本的、多订阅者,基于zookeeper协调的分布式日志系统(也可以当做MQ系统),常见可以用于web/nginx日志、访问日志,消息服务等等。

1、启动kafka服务

bin/kafka-server-start.shconfig/server.properties&

2、停止kafka服务

./kafka-server-stop.sh

3、查看所有的话题

./kafka-topics.sh--list--zookeeperlocalhost:9092

4、查看所有话题的详细信息

./kafka-topics.sh--zookeeperlocalhost:2181--describe

5、列出指定话题的详细信息

./kafka-topics.sh--zookeeperlocalhost:2181--describe--topicdemo

6、删除一个话题

./kafka-topics.sh--zookeeperlocalhost:2181--delete--topictest

7、创建一个叫test的话题,有两个分区,每个分区3个副本

./kafka-topics.sh--zookeeperlocalhost:2181--create--topictest--replication-factor3--partitions2

8、测试kafka发送和接收消息(启动两个终端)

#发送消息(注意端口号为配置文件里面的端口号)./kafka-console-producer.sh--broker-listlocalhost:9092--topictest#消费消息(可能端口号与配置文件保持一致,或与发送端口保持一致)./kafka-console-consumer.sh--bootstrap-serverlocalhost:9092--topictest--from-beginning#加了--from-beginning重头消费所有的消息./kafka-console-consumer.sh--bootstrap-serverlocalhost:9092--topictest#不加--from-beginning从最新的一条消息开始消费

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

./kafka-run-class.shkafka.tools.GetOffsetShell--broker-listlocalhost:9092--topictest--time-1

10、显示所有消费者

./kafka-consumer-groups.sh--bootstrap-serverlocalhost:9092--list

11、获取正在消费的topic(console-consumer-63307)的group的offset

./kafka-consumer-groups.sh--describe--groupconsole-consumer-63307--bootstrap-serverlocalhost:9092

11、显示消费者

./kafka-consumer-groups.sh--bootstrap-serverlocalhost:9092--list

以上是“kafka常用命令有哪些”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注亿速云行业资讯频道!