kafka _命令行操作

#啟動zk zkServer.start #啟動kafka kafka-server-start.sh -daemon /opt/kafka/config/server.properties#查看當前服務器中的所有topic kafka-topics.sh --zookeeper henu4:2181 --list#創建topic kafka-topics.sh --zookeeper henu4:2181 --create --replication-factor 3 --partitions 1 --topic first選項說明： --topic 定義topic名 --replication-factor 定義副本數 --partitions 定義分區數#刪除topic kafka-topics.sh --zookeeper henu4:2181 --delete --topic first#發送消息創建second主題kafka-topics.sh --zookeeper henu4:2181 --create --replication-factor 3 --partitions 3 --topic second#換一個節點：kafka-console-producer.sh --broker-list henu2:9092 --topic second#消費信息 kafka-console-consumer.sh --zookeeper henu2:2181 --from-beginning --topic second #如果版本問題不能使用，將--zookeeper 換成 --bootstrap-server--from-beginning：會把first主題中以往所有的數據都讀取出來。根據業務場景選擇是否增加該配置。#查看某個Topic的詳情 kafka-topics.sh --zookeeper henu2:2181 --describe --topic second#關閉集群 kafka-server-stop.sh stop

結果展示：

另一個節點：?

然后本節點消費信息：

查看某個Topic的詳情

總結

以上是生活随笔為你收集整理的kafka _命令行操作的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。