kafka常用命令有哪些
这篇文章主要介绍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常用命令有哪些”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注亿速云行业资讯频道!
声明:本站所有文章资源内容,如无特殊说明或标注,均为采集网络资源。如若本站内容侵犯了原著者的合法权益,可联系本站删除。