1.pull docker ,在机器上下载最新版本的kafka和zookeeper镜像,这里使用的是wurstmeister的镜像
docker pull wurstmeister/kafka
docker pull wurstmeister/zookeeper
启动 zookeeper
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
启动kafka
docker run -d –name kafka1 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.13.128:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.13.128:9092 -e KAFKA_LISTdocker run -d --name kafka1 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.13.128:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.13.128:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
ENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
进入容器
docker exec -it kafka1 bash
启动集群第二个机器
启动第二个kafka容器命名为kafka2,其zk地址与kafka1一致,broker_id为1,服务端口号为9093
然后进入kafka容器创建第二个topic名为test2,副本数2,分区2
docker run -d --name kafka2 -p 9093:9093 -e KAFKA_BROKER_ID=1 -e KAFKA_ZOOKEEPER_CONNECT=192.168.13.128:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.13.128:9093 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9093 -t wurstmeister/kafka