首先確保自己的linux環境下正確安裝了Java 8+，
1：取得KAFKA
https://mirrors.bfsu.edu.cn/apache/kafka/2.6.0/kafka_2.13-2.6.0.tgz下載最新的Kafka版本并解壓縮：
tar -xzf kafka_2.13-2.6.0.tgz cd kafka_2.13-2.6.0
2：啟動KAFKA環境
運行以下命令以正確的順序啟動zookeeper服務：
bin/zookeeper-server-start.sh config/zookeeper.properties
打開另一個終端會話并運行啟動kafka服務：
bin/kafka-server-start.sh config/server.properties
成功啟動所有服務后，您將運行并可以使用基本的Kafka環境，
3：建立主題來儲存您的活動
事件被組織并存盤在 主題中，非常簡化，主題類似于檔案系統中的檔案夾，事件是該檔案夾中的檔案，
因此，在撰寫第一個事件之前，必須創建一個主題，打開另一個終端會話并運行：
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
查看新主題的磁區數：
bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
4：將一些事件寫入主題
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092 This is my first event This is my second event
隨時停止生產者客戶Ctrl-C，
5：閱讀事件
打開另一個終端會話并運行控制臺使用者客戶端以讀取您剛剛創建的事件：
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
This is my first event
This is my second event隨時停止消費者客戶Ctrl-C，
隨時嘗試：例如，切換回生產者終端（上一步）以撰寫其他事件，并查看事件如何立即顯示在消費者終端中，
6：終止KAFKA環境
Ctrl-C如果尚未 停止生產者和消費者客戶，請使用，- 通過停止Kafka經紀人
Ctrl-C， - 最后，使用停止ZooKeeper服務器
Ctrl-C，
如果您還想洗掉本地Kafka環境的任何資料，包括您在此程序中創建的所有事件，請運行以下命令：
rm -rf /tmp/kafka-logs /tmp/zookeeper
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/170833.html
標籤：大數據