1.直接啟動(dòng)kafka&zookeeper:

zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &kafka-server-start /usr/local/etc/kafka/server.properties &

或通過brew services插件啟動(dòng)

brew services start zookeeper

brew services start kafka

2.啟動(dòng)Kafka Manager：

進(jìn)入到kafka Manager目錄下，cd /Users/xingshulin/Downloads/Kafka/kafka-manager-1.3.3.7

執(zhí)行nohup bin/kafka-manager -Dconfig.file=conf/application.conf

3.進(jìn)入到Kafka Manager頁面localhost:9000,點(diǎn)擊Add Cluster 添加集群

4.填寫完前兩項(xiàng)就可保存，剩下的選項(xiàng)根據(jù)自己的需求進(jìn)行勾選，這里我只填寫了集群名稱和zookeeper主機(jī)地址

5.創(chuàng)建topic

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

終端輸入顯示

6.查看創(chuàng)建的topic

kafka-topics --list--zookeeper localhost:2181

終端顯示

kafka manager顯示

注：可通過Add Partitions按鈕對(duì)topic進(jìn)行添加分區(qū)

7.發(fā)送消息

kafka-console-producer --broker-list localhost:9092 --topictest

注：這里輸入的時(shí)候建議將localhost換成本機(jī)的ip地址，這里localhost容易出現(xiàn)識(shí)別出錯(cuò)的問題

發(fā)送消息：hello world!

8.消費(fèi)消息

kafka-console-consumer --bootstrap-server localhost:9092--topic test --from-beginning

注：1.這里輸入的時(shí)候建議將localhost換成本機(jī)的ip地址，這里localhost容易出現(xiàn)識(shí)別出錯(cuò)的問題

? ? ? ? 2.producer發(fā)送消息和consumer消費(fèi)消息要建立兩個(gè)終端

接受到了消息:hello world!