kafka 單機環境搭建

1. 安裝zookeeper

kafka要先安裝zookepper

1.1下載下傳解壓zookeeper

1.2 conf/zoo_sample.cfg  複制為zoo.cfg

dataDir=/Users/walle/data/zookeeper  修改下dataDir 目錄即可

1.3 運作zookeeper

zkServer.sh start

2. 下載下傳解壓kafka

3. 修改 config/server.properties

host.name=localhost

log.dirs=/Users/walle/data/log/kafka

zookeeper.connect=localhost:2181

4. 建立一個topic

​

​bin​

​​

​/kafka-topics​

​​

​.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ​

​​

​test​

​

5. 發送消息

​

​bin​

​​

​/kafka-console-producer​

​​

​.sh --broker-list localhost:9092 --topic ​

​​

​test​

​

6. 消費消息

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning