mac 安裝Kafka

閱讀目錄

• 1. 安裝zookeeper
• 2. 啟動zookeeper 服務
• 3. 安裝kafka
• 4. 修改Kafka服務配置文件
• 5. 啟動Kafka服務
• 6. 新建topic
• 7. 創建生產者
• 8. 創建消費者

回到頂部

1. 安裝zookeeper

brew install zookeeper

默認安裝位置

啟動文件： /usr/local/Cellar/zookeeper/3.4.10/bin/

配置文件： /usr/local/etc/zookeeper/               

回到頂部

2. 啟動zookeeper 服務

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

回到頂部

3. 安裝kafka

brew install kafka

回到頂部

4. 修改Kafka服務配置文件

修改配置文件 /usr/local/etc/kafka/server.properties

解除注釋: listeners=PLAINTEXT://localhost:9092

回到頂部

5. 啟動Kafka服務

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

回到頂部

6. 新建topic

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

查看已有主題list

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

修改分區數

kafka-topics --zookeeper localhost:2181 --alter --topic topic_a  --partitions 2

回到頂部

7. 創建生產者

kafka-console-producer --topic topic_a --broker-list localhost:9092

回到頂部

8. 創建消費者

kafka-console-consumer --bootstrap-server localhost:9092 -topic topic_a