1. 复制config/server.properties
为server1.properties
和server2.properties
2. 以server1.properties
为例,修改配置
broker.id=1
listeners=PLAINTEXT://:9093
log.dirs=E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1\kafka-logs1
zookeeper.connect=localhost:12181,localhost:12182,localhost:12183
3. 启动ZooKeeper集群
配置ZooKeeper集群可参考
4. 启动Kafka集群
分别启动配置的server1和server2
.inwindowskafka-server-start.bat .configserver1.properties
.inwindowskafka-server-start.bat .configserver2.properties
5. 验证集群成功
在一个Kafka上启动一个生产者:
PS E:Developkafka2.11-2.1.1kafka_2.11-2.1.1> .inwindowskafka-console-producer.bat --broker-list localhost:9093 --topic test
在另一个Kafka上启动一个消费者:
PS E:Developkafka2.11-2.1.1kafka_2.11-2.1.1> .inwindowskafka-console-consumer.bat --bootstrap-server localhost:9094 --topic test
如果,生产者上发送的消息,在消费者上可以接收到,证明集群成功。