安裝
1.下載kafka_2.13-3.0.0.tar 不同版本，命令稍有不同（2.13是scala版本，3.0.0是kafka版本）
2.放到/usr/local/share/kafka
3.解壓tar -xvf kafka_2.13-3.0.0.tar
4.修改名字mv kafka_2.13-3.0.0 kafka3
單機測試，不修改zookeeper.properties 和 server.properties
1.啟動zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
使用 bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 以守護進程啟動
2. 啟動kafka
bin/kafka-server-start.sh -daemon config/server.properties
3.創建topic
bin/kafka-topics.sh --create --topic topicName --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
//--bootstrap-server localhost:9092 指定consumer,由kafka來維護信息； 老的使用--zookeeper ip:2181，這樣就由zk來維護信息。
//官網沒有指定partitions，命令運行后會提示你指定
//創建topic過程的問題，replication-factor個數不能超過 broker 的個數
//操作系統重啟后，需要重新創建
4.查看所有topic
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
5.查看topic
bin/kafka-topics.sh --describe --topic name --bootstrap-server localhost:9092
6.生產消息（write event）
bin/kafka-console-producer.sh --topic name --bootstrap-server localhost:9092
This is my first event （回車即表示一條結束）
This is my second event
control+c 退出
7.消費消息（read event）
bin/kafka-console-consumer.sh --topic name --from-beginning --bootstrap-server localhost:9092
This is my first event
This is my second event
8.刪除topic
bin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic topicName