Kafka集群启动

Kafka集群启动

现在有三台服务器分别是：8.8.8.101、8.8.8.102、8.8.8.103

一、分别修改三台服务器Kafka的配置文件 /config/server.properties

#服务器8.8.8.101
broker.id=101
listeners=PLAINTEXT://8.8.8.101:9092
zookeeper.connect=8.8.8.101:2181,8.8.8.102:2181,8.8.8.103:2181

#服务器8.8.8.102
broker.id=102
listeners=PLAINTEXT://8.8.8.102:9092
zookeeper.connect=8.8.8.101:2181,8.8.8.102:2181,8.8.8.103:2181

#服务器8.8.8.103
broker.id=103
listeners=PLAINTEXT://8.8.8.103:9092
zookeeper.connect=8.8.8.101:2181,8.8.8.102:2181,8.8.8.103:2181

二、启动zookeeper集群

#服务器101
./zkServer.sh start

#服务器102
./zkServer.sh start

#服务器103
./zkServer.sh start

三、启动kafka

#服务器101
kafka-server-start.sh -daemon ../config/server.properties

#服务器102
kafka-server-start.sh -daemon ../config/server.properties

#服务器103
kafka-server-start.sh -daemon ../config/server.properties

四、测试

#在服务器101上创建主题
kafka-topics.sh --create --bootstrap-server 8.8.8.101:9092 --topic t01 --partitions 2 --replication-factor 2

#在服务器102创建生产者
kafka-console-producer.sh --topic t01  --bootstrap-server 8.8.8.102:9092

#在服务器101、103上分别创建消费者
 kafka-console-consumer.sh --topic t01 --bootstrap-server 8.8.8.101:9092
 kafka-console-consumer.sh --topic t01 --bootstrap-server 8.8.8.103:9092

生产消费如图：

生产消费图

分区及副本信息：

分区及副本信息