kafka 常用命令

2021-09-25 01:22:25 字數 1059 閱讀 2057

1 啟動

kafka-server-start.sh -daemon /opt/kafka_2.11-2.3.0/config/server.properties
要手動啟動集群中的所有機器

2 檢視topics列表

kafka-topics.sh --list --zookeeper hdp-01:2181,hdp-02:2181,hdp-03:2181
topics 的資訊是儲存在zookeeper裡面的，所以重新安裝kafka，之前的那些topics資訊也會在

3 檢視某個topic的資訊

kafka-topics.sh --describe --zookeeper hdp-01:2181,hdp-02:2181,hdp-03:2181 --topic testtopic
topic資訊是儲存在zookeeper裡面

4 建立topic

kafka-topics.sh --create --zookeeper hdp-01:2181,hdp-02:2181,hdp-03:2181 --replication-factor 3 --partitions 3 --topic testtopic
副本數量 <= broker數量，同個機器儲存多分沒意義

分割槽可以超過broker數量

5 topic寫入

kafka-console-producer.sh --broker-list hdp-01:9092,hdp-02:9092,hdp-03:9092 --topic testtopic
命令列的生產者

生產者往kafka裡面寫資料，只需要知道broker在**，不需要知道zookeeper在**

6 讀取資料

kafka-console-consumer.sh  --bootstrap-server hdp-01:9092,hdp-02:9092,hdp-03:9092 --topic testtopic --from-beginning
和舊版本不一樣，舊版需要zookeeper，新版本需要brokerlist

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