一,先從官網下載:http://kafka.apache.org/downloads
二,解壓壓縮包(雖然后綴是tgz,但和gz解壓方式一樣);然后mv kafka_2.12-2.3.1 /usr/local/
接着:cd /usr/local/kafka_2.12-2.3.1/,然后由於之前已經安裝和啟動了zookeeper,所以可以刪掉config下的zookeeper.properties文件【不刪也行】;
三,啟動 kafka【注意,kafka依賴的zookeeper服務的配置在server.properties里配置,默認是zookeeper.connect=localhost:2181,這里要配置遠端的zookeeper集群地址(不過我的zookeeper也是在本地)】
./bin/kafka-server-start.sh config/server.properties
四,創建topic
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic silentdoer
創建一個名為silentdoer的topic,只有一個副本,一個分區。
通過list命令查看剛剛創建的topic【輸出silentdoer】
./bin/kafka-topics.sh --list --zookeeper localhost:2181
五,啟動producer並發送消息啟動producer
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic silentdoer
此時窗口變成>輸入模式,可以發送消息了【可以直接發,只要消息沒有被消費,那么consumer啟動后也是能夠收到的】
六,在另一個終端中,啟動consumer
命令如下:
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic silentdoer --from-beginning
啟動consumer之后就可以在console中看到producer發送的消息了
可以開啟兩個終端,一個發送消息,一個接受消息。