基於Kafka的生產者消費者消息處理本地調試
(尊重勞動成果,轉載請註明出處:http://blog.csdn.net/qq_25827845/article/details/68174111冷血之心的博客)
Kafka下載地址:http://download.csdn.net/download/qq_25827845/9798176
安裝解壓就可以
配置改動zookeeper.properties 與 server.properties改動為本地路徑,如圖所看到的:
將config文件夾中的zookeeper.properties 與 server.properties復制到bin/windows下。
windows的服務腳本在bin\windows
(1)啟動服務:啟動zookeeper:
zookeeper-server-start.bat zookeeper.properties
cd到bin\windows文件夾, 並把zookeeper.properties 復制到這裏或者在命令中帶上絕對路徑
(2)啟動kafka:
kafka-server-start.bat server.properties
(3)關閉服務:在啟動服務的cmd窗體, 按ctrl+c另開窗體,
運行腳本kafka-server-stop.bat zookeeper-server-stop.bat
(4)消費測試:建立topic:
kafka-topics.bat --create --zookeeper localhost:2181--replication-factor 1 --partitions 1 --topic test_ywq
(5)建立一個Producer, 打開一個cmd窗體,運行:
kafka-console-producer.bat --broker-list localhost:9092 --topic test_ywq
(6)建立一個Consumer, 打開一個cmd窗體,運行:
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test_ywq
(7)生產和消費測試:
當在生產者的消息為hello?時。能夠看到。在消費者裏邊能夠消費到hello?
心得總結:
1. produce啟動的時候參數使用的是kafka的port
consumer啟動的時候使用的是zookeeper的port;
2.必須先創建topic才幹使用。
3.topic本質是以文件的形式儲存在zookeeper上的。
假設對你有幫助。記得點贊哦~歡迎大家關註我的博客,能夠進群366533258一起交流學習哦~
基於Kafka的生產者消費者消息處理本地調試