提示:首先需要啟動kafka服務,啟動kafka服務之前要啟動zk
檢視當前伺服器中所有的topic
./kafka-topics.sh --list --zookeeper 192.168.56.20:2181
建立topic
./kafka-topics.sh --create --zookeeper 192.168.56.20:2181 --topic first --replication-factor 1 --partitions 2
–topic topic名
–replication-factor 副本數
–partitins 分割槽數
成功建立topic之後就會在server.properties配置中寫的logs目錄下建立乙個主題+分割槽的目錄
刪除topic
./kafka-topics.sh --delete --zookeeper 192.168.56.20:2181 --topic first
注意:需要 server.properties 中設定 delete.topic.enable=true 否則只是標記刪除。
檢視topic詳情
./kafka-topics.sh --zookeeper 192.168.56.20:2181 --describe --topic first
修改分割槽數
./kafka-topics.sh --zookeeper 192.168.56.20:2181 --alter --topic first --partitions 3
控制台測試:
開啟乙個生產者
./kafka-console-producer.sh --topic first --broker-list 192.168.56.20:9092
開啟乙個消費者舊版本命令:
./kafka-console-consumer.sh --topic first --zookeeper 192.168.56.20:2181
如果使用的kafka版本較新會報zookeeper is not a recognized option
新版本命令:
./kafka-console-consumer.sh --bootstrap-server 192.168.56.20:9092 --topic first
此時在生產者會話傳送訊息,就能在消費者端收到訊息
因為其訊息佇列解耦的特點,如果消費者後來才上線,也可以消費到存在訊息佇列中的訊息 需要加–from-beginning 引數
二 Kafka命令列操作
1 檢視當前伺服器中的所有topic root hadoop102 kafka bin kafka topics.sh zookeeper hadoop102 2181 list2 建立topic root hadoop102 kafka bin kafka topics.sh zookeeper ...
Mac 本地kafka操作筆記
brew install kafkazookeeper,會預設安裝 usr local etc kafka zookeeper.properties usr local etc kafka server.properties datadir儲存路徑,預設 usr local var lib zook...
kafka操作命令
啟動 bin kafka server start.sh daemon config server 0.properties bin kafka server start.sh daemon config server 1.properties 如果有多個server broker bin kafk...