本文主要是介绍Docker中装kafka+zk，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
下载zookeeper和kafka镜像
docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka分别启动zookeeper和kafka
docker run -p 2181:2181 -v $PWD/data:/data -d zookeeper:latestdocker run -d --name kafka1 \-p 9093:9093 \-e KAFKA_BROKER_ID=1 \-e KAFKA_ZOOKEEPER_CONNECT=主机ip:2181 \-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://主机ip:9093 \-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9093 -t wurstmeister/kafka然后docker ps
进入kafka里
docker exec -it ${CONTAINER ID} /bin/bashcd opt
cd kafka_2.11-2.0.0
(下面内容需要在两个会话中分别执行)
创建topic
bin/kafka-topics.sh --create --zookeeper 主机ip:2181 --replication-factor 1 --partitions 1 --topic dflog创建消费者
bin/kafka-console-producer.sh --broker-list 主机ip:9093 --topic dflog #生产者bin/kafka-console-consumer.sh --bootstrap-server 主机ip:9093 --topic dflog --from-beginning #消费者
这篇关于Docker中装kafka+zk的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
