雜記三 kafka常用命令

2021-10-13 13:07:08 字數 1627 閱讀 1179

1、列出集群裡的所有topic

kafka-topics.sh --zookeeper localhost:


2181


--list
2、 建立topic

topic名稱為topic_01，包含3分割槽,每個分割槽擁有3個副本

kafka-topics.sh --zookeeper localhost:


2181


--create --topic topic_01 --replication-factor 3


--partitions 3
3、列出集群裡特定topic的詳細資訊

kafka-topics.sh --zookeeper localhost:


2181


--describe  --topic topic_01
4、生產資料

不帶key

kafka-console-producer.sh --broker-list 127.0


.0.1


:9092


--topic topic1
帶key

kafka-console-producer.sh --topic a_test_test --broker-list 127.0


.0.1


:9092


--property "parse.key=true"


--property "key.separator=:"
–property 「parse.key=true」 ：開啟帶key模式

–property 「key.separator=:」：設定key和value之間的分隔符（這裡為「：」）

生產的資料格式

1234:

5、消費資料

kafka-console-consumer.sh --zookeeper localhost:


2181


--topic topic1 --group group_test1 --from-beginning
或者

kafka-console-consumer.sh --bootstrap-server localhost:


9092


--topic topic1 --group group_test1 --from-beginning
消費帶key的資料

kafka-console-consumer.sh --zookeeper localhost:


2181


--topic topic1  --group group_test1 --from-beginning --property print.key=


true


--property key.separator=


:
–from-beginning：表示從頭開始消費

三 kafka常用命令

1.啟動kafka bin kafka server start.sh daemon config server.properties 2.關閉kafka bin kafka server stop.sh 3.檢視kafka topic是否支援集群，沒反應就是正確 bin kafka topics....

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