技術標籤：JavaEE57

文章目錄

• Kafka常用命令

Kafka常用命令

#啟動kafka
kafka-server-start.sh -daemon config/server.properties
#關閉kafka
kafka-server-stop.sh stop
#檢視當前伺服器中的所有topic
kafka-topics.sh --zookeeper 127.0.0.1:2981 --list
#建立topic  replication-factor 定義副本數 partitions定義分割槽數
kafka-topics.sh --zookeeper 127.0.0.1:2981 --create --replication-factor 1 --partitions 1 --topic first
#刪除topic
 

kafka-topics.sh --zookeeper 127.0.0.1:2981 --delete --topic first
#傳送訊息
kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic first
#消費訊息
kafka-console-consumer.sh --zookeeper 127.0.0.1:2981 --topic first

#檢視某個Topic的詳情
kafka-topics.sh --zookeeper 127.0.0.1:2981 --describe --topic first

#修改分割槽數
kafka-topics.sh --zookeeper 127.0.0.1:2981 --alter --topic first --partitions 2


#linux定義命令
 

vi /root/.bashrc
alias kafka='cd /usr/local/kafka/bin;pwd'