Linux安裝kafka2.3.1基於Scala2.12


一,先從官網下載: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發送的消息了

可以開啟兩個終端,一個發送消息,一個接受消息。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM