docker搭建kafka+zookeeper

1.找到并拉取kafka和zookeeper鏡像

docker search kafka
docker search zookeeper
           

我們統一拉取這兩個

docker pull wurstmeister/kafka
docker pull wurstmeister/zookeeper
           

2.運作zookeeper

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

3.運作kafka

配置中kafka的端口為9092，zookeeper連接配接到容器名為zookeeper開放的2181端口，我這裡docker主控端ip為192.168.251.10，把主控端的本地時間同步給kafka

docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 --env KAFKA_ADVERTISED_HOST_NAME=192.168.251.10 --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime wurstmeister/kafka:latest
           

4.docker ps檢視确認啟動正常

5.建立topic，我這裡就叫做test0

/opt/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test0
           

6.檢視消息

/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test0 --from-beginning