安裝啓動kafka

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