當前開發環境：CentOS7,kafka_2.12-2.8.0.tgz

1.宣告

當前內容主要為學習和測試使用Apache Kafka的基本demo,當前內容主要來源：Apache Kafka官方demo

主要為：

1. 啟動kafka
2. 使用命令列方式建立topic
3. 向當前建立的topic中釋出和訂閱訊息

2.基本demo

當前的kafka中需要先啟動zookeeper,否則直接啟動當前的kafka會出現不斷的錯誤

啟動成功後就可以執行建立topic的命令了

1.建立topic（名稱為test-events的主題）

./bin/kafka-topics.sh --create --topic test-events --bootstrap-server 192.168.1.101:9092
 

結果：

2.檢視建立的topic（主要為--describe）

./bin/kafka-topics.sh --describe --topic test-events --bootstrap-server 192.168.1.101:9092

3.開始連線這個test-events主題的釋出端

./bin/kafka-console-producer.sh --topic test-events --bootstrap-server 192.168.1.101:9092

等待，並按下回車，進入》介面

4.啟動消費者並訂閱test-events主題的訊息

./bin/kafka-console-consumer.sh --topic test-events --from-beginning --bootstrap-server 192.168.1.101:9092
 

5.開始向該topic上釋出訊息，以及檢視訊息

此時訊息只要傳送那麼，這邊訊息立刻接收

測試成功！基本上就是一個官方的入門demo