vim kafka/config/server.properties

#確保唯一
broker.id=0
#允許刪除主題
delete.topic.enable=true
# 指定資料檔案所在目錄
log.dirs=/var/local/kafka/logs
#zookeeper 的連線地址
zookeeper.connect=localhost:2181

啟動kafka

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

#檢視程序，帶上全類名

jps -l 

#建立主題，一個分割槽，一個備份

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

#檢視kafka的主題

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

#生產者產生資料

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

#啟動消費者

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

不跟zk互動，改跟kafka互動，提高效率

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