環境準備：

1.Zookeeper分散式環境，連線字串為master:2182,slave1:2182,slave2

2.Kafka Standalone環境, kafka安裝於slave1。

Kafka配置：

1.connect-standalone.properties 中修改主機名localhost, bootstrap.servers=slave1:9092

2.producer.properties中修改主機名localhost, bootstrap.servers=slave1:9092

3.zookeeper.properties修改clientPort為2182

4.consumer.properties修改zookeeper連線字串，zookeeper.connect=master:2182,slave1:2182,slave2:2182

5.server.properties

 listeners=PLAINTEXT://slave1:9092
#host.name=slave1
#port=9092

advertised.listeners=PLAINTEXT://slave1:9092
#advertised.host.name=slave1
#advertised.port=9092

zookeeper.connect=master:2182,slave1:2182,slave2:2182

啟動console-producer時，不停報LEADER_NOT_AVAILABLE錯誤，首先檢查配置是否正確，其次有可能topic建立方式不對。

建立topic --> bin/kafka-topics.sh --create --zookeeper master:2182,slave1:2182,slave2:2182 --replication-factor 1 --partitions 1 --topic test

bin/kafka-topics.sh --list --zookeeper master:2182,slave1:2182,slave2:2182

生產bin/kafka-console-producer.sh --broker-list slave1:9092 --topic test1

消費bin/kafka-console-consumer.sh --zookeeper master:2182,slave1:2182,slave2:2182 --topic test1 --from-beginning