Kafka的安裝與使用

kafka是乙個分布式的訊息佇列，一般在整個系統中起到解耦，削峰，非同步處理的作用。整個系統分為消費者和生產者，生產者往裡面寫入資料，消費者取出資料進行邏輯處理。

其實zookeeper就是乙個服務註冊和發現中心。kafka使用zookeeper來進行動態的集群擴充套件，不需要修改客戶端的配置。

在開啟kafka伺服器之前一定要先開啟zookeeper伺服器，負責會報錯。

進入zookeeper安裝目錄\bin，開啟zkserver.cmd，就可以看見已經繫結了本機的2181埠

進入kafka的安裝目錄，同時按shift和滑鼠右鍵，開啟命令列工具，輸入.\bin\windows\kafka-server-start.bat .\config\server.properties，就可以開啟kafka伺服器了。

重新開乙個命令列視窗，輸入.\bin\windows\kafka-topices.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1--topic dblab ，建立乙個topic

然後開啟乙個生產者，在剛才的視窗下輸入.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic dblab

再開啟乙個消費者視窗，輸入.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 dblab --from -beginning

然後你在生產者的視窗輸入字元，會看見消費者也會有同樣的字元輸出,我們的kafka就安裝成功了。