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