kafka常用命令

1、啟動kafka服務

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

2、停止kafka服務

./kafka-server-stop.sh

3、檢視所有的話題

bin/kafka-topics.sh --list --zookeeper node7-1:2181,node7-2:2181,node7-3:2181

bin/kafka-topics.sh --list --bootstrap-server node7-1:9092,node7-2:9092,node7-3:9092,node7-4:9092

4、檢視所有話題的詳細資訊

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

5、列出指定話題的詳細資訊

bin/kafka-topics.sh --describe --zookeeper node7-1:2181,node7-2:2181,node7-3:2181 --topic test

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

bin/kafka-topics.sh --create --zookeeper node7-1:2181,node7-2:2181,node7-3:2181 --replication-factor 1 --partitions 1 --topic test

8、測試kafka傳送和接收訊息（啟動兩個終端）

#傳送訊息（注意埠號為配置檔案裡面的埠號）

bin/kafka-console-producer.sh --broker-list node7-1:9092,node7-2:9092,node7-3:9092,node7-4:9092 --topic test

#消費訊息（可能埠號與配置檔案保持一致，或與傳送埠保持一致）

bin/kafka-console-consumer.sh --bootstrap-server node7-1:9092,node7-2:9092,node7-3:9092,node7-4:9092 --topic test1 --from-beginning

./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

1、啟動kafka服務

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

2、停止kafka服務

./kafka-server-stop.sh

3、檢視所有的話題

bin/kafka-topics.sh --list --zookeeper node7-1:2181,node7-2:2181,node7-3:2181

bin/kafka-topics.sh --list --bootstrap-server node7-1:9092,node7-2:9092,node7-3:9092,node7-4:9092

4、檢視所有話題的詳細資訊

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

5、列出指定話題的詳細資訊

bin/kafka-topics.sh --describe --zookeeper node7-1:2181,node7-2:2181,node7-3:2181 --topic test

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

bin/kafka-topics.sh --create --zookeeper node7-1:2181,node7-2:2181,node7-3:2181 --replication-factor 1 --partitions 1 --topic test

8、測試kafka傳送和接收訊息（啟動兩個終端）

#傳送訊息（注意埠號為配置檔案裡面的埠號）

bin/kafka-console-producer.sh --broker-list node7-1:9092,node7-2:9092,node7-3:9092,node7-4:9092 --topic test

#消費訊息（可能埠號與配置檔案保持一致，或與傳送埠保持一致）

bin/kafka-console-consumer.sh --bootstrap-server node7-1:9092,node7-2:9092,node7-3:9092,node7-4:9092 --topic test1 --from-beginning

./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常用命令

kafka常用操作命令 l檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper hadoop02 2181 l建立topic kafka topics.sh create zookeeper hadoop02 2181 replication fac...

kafka常用命令

啟動集群 nohup bin kafka server start.sh config server.properties 建立topic kafka topics topictt replication factor3 partitions3 create zookeeper hadoop1 21...

Kafka 常用命令

kafka console producer broker list 127.0.0.1 9092 topic mytopic kafka console consumer bootstrap server 127.0.0.1 9092 topic mytopic 建立主題,replication ...