依賴環(huán)境

kafka依賴zookeeper，故先要進行zookeeper部署，詳見centos7 zookeeper部署。

?

kafka下載

http://kafka.apache.org/downloads
http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.3.1/kafka_2.12-2.3.1.tgz

部署

tar xvzf kafka_2.12-2.3.1.tgz
mv kafka_2.12-2.3.1 /opt/
cd /opt/kafka_2.12-2.3.1/
vi config/server.properties
修改

listeners=PLAINTEXT://192.168.81.145:9092 ? ?#注意，這里一定要有客戶端可訪問的ip，否則非本機連接調(diào)用第二次會異常
log.dirs=/data/kafka-logs

啟動
bin/kafka-server-start.sh config/server.properties &
如果輸出出現(xiàn)
[2019-11-18 15:17:08,052] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)
表示成功啟動

停止服務(wù)
bin/kafka-server-stop.sh?

測試

啟動生產(chǎn)者
bin/kafka-console-producer.sh --broker-list 192.168.81.145:9092 --topic test
然后隨便輸入幾行消息

啟動消費者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.81.145:9092 --topic test --from-beginning
消費者會獲取到生產(chǎn)者輸入的幾行消息

?

單機偽集群部署詳見下篇文章：centos7 kafka單機偽集群部署

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的centos7 kafka2.3.1单点部署的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。