基于Docker搭建Kafka集群

前提准备

这里集群采用三台机器 分别是138、139和141

1、拉镜像

在机器上下载最新版本的kafka和zookeeper镜像，这里使用的是wurstmeister的镜像

docker pull wurstmeister/kafka
docker pull wurstmeister/zookeeper

iptables -I INPUT -p tcp --dport 9092 -j ACCEPT
iptables -I INPUT -p tcp --dport 2181 -j ACCEPT

2、启动138zookeeper

docker run -d 
--name zookeeper 
-p 2181:2181 
-t wurstmeister/zookeeper

3、启动138kafka

docker run -d --name kafka1 
-p 9092:9092 
#broker 的全局唯一编号，不能重复
-e KAFKA_BROKER_ID=0
-e delete.topic.enable=true
#topic 在当前 broker 上的分区个数 
-e num.partitions=1 
-e KAFKA_ZOOKEEPER_CONNECT=192.168.190.138:2181 
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.190.138:9092 
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
-t wurstmeister/kafka

4、启动139kafka

docker run -d --name kafka2 
-p 9092:9092 
-#broker 的全局唯一编号，不能重复
-e KAFKA_BROKER_ID=1
-e delete.topic.enable=true
#topic 在当前 broker 上的分区个数 
-e num.partitions=1 
-e KAFKA_ZOOKEEPER_CONNECT=192.168.190.138:2181 
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.190.139:9092 
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
-t wurstmeister/kafka

5、启动141kafka

docker run -d 
--name kafka3 
-p 9092:9092 
-e KAFKA_BROKER_ID=2 
-e delete.topic.enable=true 
-e num.partitions=1 -e KAFKA_ZOOKEEPER_CONNECT=192.168.190.138:2181 
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.190.141:9092 
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
-t wurstmeister/kafka

5、用代码测试

6、客户端链接查看信息