1.啟動kafka
bin/kafka-server-start.sh -daemon config/server.properties
2.關閉kafka
bin/kafka-server-stop.sh
3.檢視kafka topic是否支援集群，沒反應就是正確
bin/kafka-topics.sh --describe --zookeeper 1.1.1.1:2181,1.1.1.2:2181,1.1.1.3:2181 --topic mytopic
4.檢視當前zookerrper下的kafka集群所有的topic
bin/kafka-topics.sh --list --zookeeper 1.1.1.1:2181
5.詳細檢視topic
bin/kafka-topics.sh --describe --zookeeper 1.1.1.1:2181 --topic topic名字
6.建立乙個topic，副本備份數1個，分割槽數1個
bin/kafka-topics.sh --create --zookeeper 1.1.1.1:2181 --replication-factor 1 --partitions 1 --topic topic名字
7.刪除乙個topic
bin/kafka-topics.sh --zookeeper 1.1.1.1:2181 --delete --topic topic名字
8.改變集群模式為主主，切換主從到主主模式，解決主從模式下，從從選舉時間問題
bin/kafka-preferred-replica-election.sh --zookeeper 1.1.1.1:2181
以 sync 模式啟動乙個producer，test是topic名
bin/kafka-console-producer.sh --broker-list 192.168.1.24:9092 --sync --topic test
然後，輸入以下內容：
hello, world!
啟動乙個 consumer，在另乙個終端執行：
bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.24:9092 --topic test --from-beginning
觀察輸出，你會看到下面內容：
hello, world!
雜記三 kafka常用命令
1 列出集群裡的所有topic kafka topics.sh zookeeper localhost 2181 list2 建立topic topic名稱為topic 01，包含3分割槽,每個分割槽擁有3個副本 kafka topics.sh zookeeper localhost 2181 cr...
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...