參考:https://www.jianshu.com/p/8ccd712e2599docker
搭建過程bootstrap
1. 下載zookeeper鏡像bash
docker pull wurstmeister/zookeeper
2. 下載kafka鏡像spa
docker pull wurstmeister/kafka
3. 建立一個docker-compose.yml文件code
version: '2' services: zookeeper: image: wurstmeister/zookeeper ports: - "2181:2181" kafka: image: wurstmeister/kafka ports: - "9092" environment: KAFKA_ADVERTISED_HOST_NAME: "192.168.99.100" KAFKA_ZOOKEEPER_CONNECT: 192.168.99.100:2181 volumes: - /var/run/docker.sock:/var/run/docker.sock
4. 啓動docker-composeserver
docker-compose up -d
5. 運行kafka集羣模式blog
docker-compose scale kafka=3
6. 查看containerkafka
docker ps docker ps -a
7. 進入指定容器it
docker exec -it dockertoolbox_kafka_1 /bin/bash
8. 建立Topicio
$KAFKA_HOME/bin/kafka-topics.sh --create --topic test \ --zookeeper dockertoolbox_zookeeper_1:2181 --replication-factor 1 --partitions 1
9. 查看建立的topic
$KAFKA_HOME/bin/kafka-topics.sh --zookeeper
dockertoolbox_zookeeper_1:2181 \ --describe --topic test
10. 發佈消息
$KAFKA_HOME/bin/kafka-console-producer.sh --topic=test \ --broker-list dockertoolbox_kafka_1:9092
11. 接受消息
$KAFKA_HOME/bin/kafka-console-consumer.sh--bootstrap-server dockertoolbox_kafka_1:9092--from-beginning --topic test