Kafka常用命令操作

2021-08-28 06:20:50 字數 1079 閱讀 3437

1.建立topic(主題)

bin/kafka-topics.sh --zookeeper cdh0:2181 --create --replication-factor 3 --partitions 3 --topic first
說明：   

--topic：定義topic名

--replication-factor：  定義副本數

--partitions：  定義分割槽數

2.檢視當前伺服器中所有topic

bin/kafka-topics.sh --zookeeper cdh0:2181 --list
3.刪除topic

bin/kafka-topics.sh --zookeeper cdh0:2181 --delete --topic first
注意： 

新版本的可以直接刪除，舊版本的kafka需要server.properties中設定delete.topic.enable=true，否則只是標記刪除或者直接重啟

4.傳送訊息

bin/kafka-console-producer.sh --broker-list cdh1:9092 --topic test
5.消費訊息

bin/kafka-console-consumer.sh --bootstrap-server cdh0:9092 --topic test --from-beginning
注意： 

--from-beginning： 會把first主題中以往所有的資料都讀取出來，應根據業務場景選擇是否需要該配置

6.檢視某個topic的詳情

bin/kafka-topics.sh --zookeeper cdh0:2181 --describe --topic test

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