安裝 kafka
(安裝kafka前應在本地先安裝java的jdk，因為zookeeper需要依賴java虛擬機)
下載地址：https://kafka.apache.org/down…

wget http://mirrors.shuosc.org/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz
解壓：

tar -zxvf kafka_2.11-2.0.0.tgz cd /usr/local/kafka_2.11-2.0.0/

修改 kafka-server 的配置文件

vim /usr/local/kafka/config/server.properties

修改其中的：

broker.id=1 log.dir=/data/kafka/logs-1

功能驗證：
1、啟動 zk
使用安裝包中的腳本啟動單節點 Zookeeper 實例：

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

2、啟動Kafka 服務
使用 kafka-server-start.sh 啟動 kafka 服務：

bin/kafka-server-start.sh config/server.properties

3、創建 topic
使用 kafka-topics.sh 創建單分區單副本的 topic test：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看 topic 列表：

bin/kafka-topics.sh --list --zookeeper localhost:2181

4、產生消息
使用 kafka-console-producer.sh 發送消息：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

5、消費消息
使用 kafka-console-consumer.sh 接收消息并在終端打印：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。