1.最好是配置成三台，这里我只有2台机器，就这样配置了。
2.kafka各个节点配置 ,gk-1节点对应的机器 /etc/hosts如下：
![\"\"](\"/images/csdn/15455711136h15455ax71113.png\")
3. kafka配置文件，server.properties
isteners=PLAINTEXT://:9092
zookeeper.connect=localhost:2181
broker.id=0 (其他kafka节点依次配置1,2,3...)
ps:zookeeper先配置成集群
iptables开放端口9092（kafka通讯端口），2181
4. 各节点server.properties配置各自的 advertised.host.name 和port 用于外网发现。gk-1节点对应的机器对应的节点机器配置如下：
![\"\"](\"/images/csdn/15455711131u5WF4557111A3.png\")
5.到此 服务器配置完毕。 可以使用bin/kafka-server-start.sh config/server.properties启动，下面命令用于测试
生产：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-replicated-topic
消费：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic my-replicated-topic
6.代码对应的机器还需要配置各个节点的hosts,如我windows本机配置：
![\"\"](\"/images/csdn/15455711131545w5sPy71113.png\")
ps:
kafka发布消息报错LEADER_NOT_AVAILABLE:
zookeeper-shell.sh gk-0,gk-1 查看是否缺少broker
参考：
版权声明
本文仅代表作者观点，不代表百度立场。
本文系作者授权百度百家发表，未经许可，不得转载。
