下載kafka安裝包：http://archive.apache.org/dist/kafka/

解壓檔案，修改kafka的config/server.properties裡面的配置

server.properties配置中需要關注以下幾個引數：

# The id of the broker. This must be set to a unique integer for each broker.
# 表示broker的編號，如果叢集中有多個broker，則每個broker的編號需要設定的不同
broker.id=0
# listeners=PLAINTEXT://0.0.0.0:9092
# broker對外提供的服務入口地址
listeners
 
=PLAINTEXT://192.168.110.142:9092
# 設定存放訊息日誌的地址
# A comma separated list of directories under which to store log files
log.dirs=/tmp/kafka-logs
# zookeeper.connect=localhost:2181
# kafka所需的zookeeper的叢集地址
zookeeper.connect=192.168.110.142:2181

如需要叢集環境內外網區分，需關注 kafka的listeners 和advertised.listeners 詳細配置

修改完畢後，啟動

命令：

建立topic

./kafka-topics.sh -zookeeper 192.168.0.20:218 -topic test -replication-factor 2 -partitions 5 --create

檢視當前topic

./kafka-topics.sh -zookeeper 192.168.0.20:2181 -list

建立生產者生產資料

./kafka-console-producer.sh --broker-list 192.168.0.20:9092 --topic test

建立消費者消費資料

kafka-console-consumer.sh --bootstrap-server 192.168.0.20:9092 --topic canal_topic --from-beginning

刪除topic

kafka-topics.sh --zookeeper 192.168.0.20:2181--delete --topic test_epidemic_report