简单介绍一下kafka常用命令

Kafka是一个分布式、分区的、多副本的、多订阅者，基于zookeeper协调的分布式日志系统（也可以当做MQ系统），常见可以用于web/nginx日志、访问日志，消息服务等等，本篇文章重点为大家讲解一下kafka常用命令。

为白沙黎族等地区用户提供了全套网页设计制作服务，及白沙黎族网站建设行业解决方案。主营业务为做网站、成都网站设计、白沙黎族网站设计，以传统方式定制建设网站，并提供域名空间备案等一条龙服务，秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求，就会得到认可，从而选择与我们长期合作。这样，我们也可以走得更远！

1、启动kafka服务

bin/kafka-server-start.sh config/server.properties &

2、停止kafka服务

./kafka-server-stop.sh

3、查看所有的话题

./kafka-topics.sh --list --zookeeper localhost:9092

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

./kafka-topics.sh --zookeeper localhost:2181 --describe

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

./kafka-topics.sh --zookeeper localhost:2181 --describe  --topic demo

6、删除一个话题

./kafka-topics.sh --zookeeper localhost:2181 --delete  --topic test

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

./kafka-topics.sh --zookeeper localhost:2181 --create --topic test --replication-factor 3 --partitions 2

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

#发送消息（注意端口号为配置文件里面的端口号）
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
#消费消息（可能端口号与配置文件保持一致，或与发送端口保持一致）
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning   #加了--from-beginning 重头消费所有的消息./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test         #不加--from-beginning 从最新的一条消息开始消费

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

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

10、显示所有消费者

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

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

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

11、显示消费者

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

文章名称：简单介绍一下kafka常用命令
本文地址：http://www.shufengxianlan.com/qtweb/news21/287021.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联