broker.id=0 listeners=PLAINTEXT://127.0.0.1:9092 port=9092 host.name=127.0.0.1 log.dirs=/opt/kafka/kafkalogs zookeeper.connect=127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183
因为我是在一台服务器搭建，可以将server.properties复制两份，分别命名为server1.properties，server2.properties，来模拟三台服务器。如果是在三台不同服务器，则不需要复制多份，只需要在三台服务器分别对server.properties进行配置即可.
#在config目录下复制两份server.properties，并命名 server-1.propertis， server-2.propertis cp server.properties server-1.propertis cp server.properties server-2.propertis
修改server1.properties如下:
broker.id=1 listeners=PLAINTEXT://127.0.0.1:9093 port=9093 host.name=127.0.0.1 log.dirs=/opt/kafka/kafkalogs1 zookeeper.connect=127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183
修改server2.properties如下:
broker.id=2 listeners=PLAINTEXT://127.0.0.1:9094 port=9094 host.name=127.0.0.1 log.dirs=/opt/kafka/kafkalogs2 zookeeper.connect=127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183
启动Kafka集群并测试1、启动服务
#从后台启动Kafka集群（3台都需要启动） #进入到kafka的根目录 cd /opt/kafka/kafka_2.11-1.0.0 #模拟启动三个配置文件,代表三台服务器. ./bin/kafka-server-start.sh -daemon config/server.properties ./bin/kafka-server-start.sh -daemon config/server1.properties ./bin/kafka-server-start.sh -daemon config/server2.properties # 启动命令中的 -daemon 表示以守护进程的方式启动.
2、测试kafka
创建主题:
#创建一个test主题，分区数为3,备份数为3 #在kafka根目录执行下面命令 bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 3 --partitions 3 --topic test
启动生产者:
#kafka根目录执行，启动一个生产者 bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
不要关闭生产者窗口，再打开一个新窗口，进入到kafka根目录，启动消费者:
#启动消费者命令 bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test --from-beginning
在生产者发送一条消息，查看消费者是否有接收成功。接收成功后kafka集成环境搭建完成。