kafka常用命令有哪些

Kafka是一個(gè)分布式、分區(qū)的、多副本的、多訂閱者，基于zookeeper協(xié)調(diào)的分布式日志系統(tǒng)（也可以當(dāng)做MQ系統(tǒng)），常見可以用于web/nginx日志、訪問日志，消息服務(wù)等等。

1、啟動(dòng)kafka服務(wù)

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

2、停止kafka服務(wù)

./kafka-server-stop.sh

3、查看所有的話題

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

4、查看所有話題的詳細(xì)信息

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

5、列出指定話題的詳細(xì)信息

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

6、刪除一個(gè)話題

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

7、創(chuàng)建一個(gè)叫test的話題，有兩個(gè)分區(qū)，每個(gè)分區(qū)3個(gè)副本

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

8、測(cè)試kafka發(fā)送和接收消息（啟動(dòng)兩個(gè)終端）

#發(fā)送消息（注意端口號(hào)為配置文件里面的端口號(hào)）./kafka-console-producer.sh --broker-list localhost:9092 --topic test#消費(fèi)消息（可能端口號(hào)與配置文件保持一致，或與發(fā)送端口保持一致）./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning   #加了--from-beginning 重頭消費(fèi)所有的消息./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test         #不加--from-beginning 從最新的一條消息開始消費(fèi)

9、查看某個(gè)topic對(duì)應(yīng)的消息數(shù)量

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

10、顯示所有消費(fèi)者

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

11、獲取正在消費(fèi)的topic（console-consumer-63307）的group的offset

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

11、顯示消費(fèi)者

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