mac kafka 環(huán)境搭建:

$ brew install kafka

安裝目錄：

/usr/local/Cellar/kafka/2.0.0

配置文件目錄：

/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.properties

操作命令：

首先啟動zookeeper：

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

然后啟動 kafka 服務(wù)：

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

創(chuàng)建topic:
讓我們使用單個分區(qū)和只有一個副本創(chuàng)建一個名為“test”的主題

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

Created topic “test”.

查看創(chuàng)建的topic:
我們現(xiàn)在可以看到該主題，如果我們運(yùn)行l(wèi)ist topic命令：

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

test

發(fā)送一些消息:
Kafka提供了一個命令行客戶端，它將從文件或標(biāo)準(zhǔn)輸入接收輸入，并將其作為消息發(fā)送到Kafka集群。默認(rèn)情況下，每行都將作為單獨(dú)的消息發(fā)送。

運(yùn)行生產(chǎn)者，然后在控制臺中鍵入一些消息發(fā)送到服務(wù)器。

$ kafka-console-producer --broker-list localhost:9092 --topic test
第一條消息
第二條消息

消費(fèi)消息
Kafka還有一個命令行消費(fèi)者，將消息轉(zhuǎn)儲到標(biāo)準(zhǔn)輸出。

$ kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
第一條消息
第二條消息

如果你有上面的每個命令運(yùn)行在不同的終端，那么你現(xiàn)在應(yīng)該能夠輸入消息到生產(chǎn)者終端，看到他們出現(xiàn)在消費(fèi)者終端。

所有命令行工具都有其他選項(xiàng); 運(yùn)行沒有參數(shù)的命令將顯示詳細(xì)記錄它們的使用信息。

總結(jié)

以上是生活随笔為你收集整理的kafka for mac安装的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。