一、环境准备

1、软件zookeeper3.4.11 kafka1.0.0 java8 2、硬件✔ 机器：10.205.104.55✔ 机器：10.205.102.52✔ 机器：10.205.105.33二、安装jdk安装略1、统一目录/opt2、安装zookeeper（三台机器同样操作）cp conf/zoo_sample.cfg zoo.cfggrep ^[^#] conf/zoo.cfg添加机器id到 dataDir=/opt/zookeeper-3.4.11/data目录下的myid文件中机器：10.205.104.55 写1机器：10.205.102.52 写2机器：10.205.105.33 写3每台机器都是同样的配置启动zookeeperbin/zkServer.sh start 检验3、安装kafka（每台机器broker.id不同。这里依此是0，1，2）每台机器依此配置启动kafka（每台都启动）bin/kafka-server-start.sh config/server-1.properties &校验创建topicbin/kafka-topics.sh --create --zookeeper 10.205.104.55:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic查看topic信息bin/kafka-topics.sh --describe --zookeeper 10.205.104.55:2181 --topic my-replicated-topic推送信息bin/kafka-console-producer.sh --broker-list 10.205.104.55:9092 --topic my-replicated-topic消费信息bin/kafka-console-consumer.sh --bootstrap-server 10.205.104.55:9092 --from-beginning --topic my-replicated-topic安装完毕最后送上优化文章：