讓我們繼續(xù)下載并設置Kafka，啟動zookeeper，集群，生產(chǎn)者和消費者。

• 要下載Kafka，請參閱此鏈接??
  http://kafka.apache.org/downloads.html
• 下載后，解壓縮然后切換到目錄

tar -xzf kafka_2.9.1-0.8.2.2.tgz
cd kafka_2.9.1-0.8.2.2

• 由于Kafka使用Zookeeper，所以首先需要啟動它，請按照以下步驟操作：

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

• 現(xiàn)在啟動Kafka服務器：

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

• 一旦服務器啟動，我們現(xiàn)在需要創(chuàng)建一個主題，說“測試”

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

• 要檢查主題是否已成功創(chuàng)建，請使用list命令：

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

• 現(xiàn)在讓我們開始生產(chǎn)者和消費者，如下所述：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test

• 現(xiàn)在通過在Producer控制臺上鍵入它來發(fā)送一些消息，一旦按下輸入，相同的消息應該是消費者控制臺上的消費者。

生成器生成的消息在Consumer上消耗后，表明您正確設置了Kafka。

轉(zhuǎn)載于:https://www.cnblogs.com/a00ium/p/10947026.html

總結(jié)

以上是生活随笔為你收集整理的设置KAFKA的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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