檢視當前伺服器中的所有 topic
bin/kafka-topics.sh --list --zookeeper zk01:2181
建立 topic
bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic test
刪除 topic
bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic test
需要 server.properties 中設定 delete.topic.enable=true 否則只是標記刪除或者直接重啟。
通過 shell 命令傳送訊息
bin/kafka-console-producer.sh --broker-list kafka01:9092 --topic test
通過 shell 消費訊息
bin/kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test
/kafka-console-consumer --bootstrap-server kafka01:9092 --from-beginning --topic test
檢視消費位置
bin/kafka-run-class.sh kafka.tools.consumeroffsetchecker --zookeeper zk01:2181 --group testgroup
檢視某個 topic 的詳情
bin/kafka-topics.sh --topic test --describe --zookeeper zk01:2181
對分割槽數進行修改
Kafka消費者生產者例項
它允許發布和訂閱記錄流，類似於訊息佇列或企業訊息傳遞系統。它可以容錯的方式儲存記錄流。它可以處理記錄發生時的流。由於主要介紹如何使用kafka快速構建生產者消費者例項，所以不會涉及kafka內部的原理。乙個基於kafka的生產者消費者過程通常是這樣的 來自官網 cd kafka 2.11 0.11....
Kafka消費者生產者例項
2017年07月30日18 22 56 rhwayfunn 閱讀數 13818標籤 kafka 更多 個人分類 分布式系統 為了更為直觀展示卡夫卡的訊息生產消費的過程，我會從基於控制台和基於應用兩個方面介紹使用例項.kafka是乙個分布式流處理平台，具體來說有三層含義 它允許發布和訂閱記錄流，類似於...
Kafka生產者和消費者
一 生產者 1 分割槽的原因 方便在集群中擴充套件 每個分割槽都可以通過調整副本數,改變分割槽副本所佔的kafka節點。每個topic又有多個分割槽,這樣就可以靈活的改變集群的大小和所佔的機器數 可以提高併發 同乙個topic的資料,可以分散到不同的分割槽,而不同的分割槽資料可以被不同的consum...