centos7 下 kafka的安裝和基本使用

首先確保自己的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環境

1. Ctrl-C如果尚未 停止生產者和消費者客戶，請使用。
2. 通過停止Kafka經紀人Ctrl-C。
3. 最后，使用停止ZooKeeper服務器Ctrl-C。

如果您還想刪除本地Kafka環境的任何數據，包括您在此過程中創建的所有事件，請運行以下命令：

rm -rf /tmp/kafka-logs /tmp/zookeeper