1，開啟zookeeper集群 startzk.sh
2，開啟kafka集群 start-kafka.sh
2，開啟kafka視覺化介面 kafka-manager ： start-kafka-manager.sh
3,生產者操作：
kafka-console-producer.sh --broker-list node1:9092 --topic my-kafka-topic //my-kafka-topic時topic的名字
4,消費者操作：
kafka-console-consumer.sh --bootstrap-server node1:9092 --topic my-kafka-topic
# 通過以上命令，可以看到消費者可以接收生產者傳送的訊息
# 如果需要從頭開始接收資料，需要新增--from-beginning引數
kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic my-kafka-topic
5,a.建立topic
kafka-topics.sh --create --zookeeper node1:2181 --replication-factor 1 --partitions 1 --topic my-kafka-topic
b.檢視topic列表
kafka-topics.sh --list --zookeeper node01:2181
c.如果需要檢視topic的詳細資訊，需要使用describe命令
kafka-topics.sh --describe --zookeeper node1:2181 --topic test-topic
d.#若不指定topic，則檢視所有topic的資訊
kafka-topics.sh --describe --zookeeper node1:2181
e.刪除topic
kafka-topics.sh --delete --zookeeper node1:2181 --topic my-kafka-topic
生產者消費者 生產者與消費者模式
一 什麼是生產者與消費者模式 其實生產者與消費者模式就是乙個多執行緒併發協作的模式，在這個模式中呢，一部分執行緒被用於去生產資料，另一部分執行緒去處理資料，於是便有了形象的生產者與消費者了。而為了更好的優化生產者與消費者的關係，便設立乙個緩衝區，也就相當於乙個資料倉儲，當生產者生產資料時鎖住倉庫，不...
Kafka消費者生產者例項
它允許發布和訂閱記錄流，類似於訊息佇列或企業訊息傳遞系統。它可以容錯的方式儲存記錄流。它可以處理記錄發生時的流。由於主要介紹如何使用kafka快速構建生產者消費者例項，所以不會涉及kafka內部的原理。乙個基於kafka的生產者消費者過程通常是這樣的 來自官網 cd kafka 2.11 0.11....
Kafka消費者生產者例項
2017年07月30日18 22 56 rhwayfunn 閱讀數 13818標籤 kafka 更多 個人分類 分布式系統 為了更為直觀展示卡夫卡的訊息生產消費的過程，我會從基於控制台和基於應用兩個方面介紹使用例項.kafka是乙個分布式流處理平台，具體來說有三層含義 它允許發布和訂閱記錄流，類似於...