1.给dockers配置国内加速镜像
https://bjimarn6.mirror.aliyuncs.com 阿里云镜像
http://hub-mirror.c.163.com 网易镜像
https://docker.mirrors.ustc.edu.cn ustc镜像
https://registry.docker-cn.com docker中国镜像
2.下载镜像
这里使用了wurstmeister/kafka和wurstmeister/zookeeper这两个版本的镜像，在hub.docker.com中可以搜索到。
1、docker pull wurstmeister/zookeeper
2、docker pull wurstmeister/kafka
3.启动
1、启动zookeeper
docker run -d --name zookeeper -p 2181 -t wurstmeister/zookeeper
2、启动kafka
docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
--env KAFKA_ADVERTISED_HOST_NAME=localhost --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime
wurstmeister/kafka:latest
可以通过docker ps查看启动状态
4.测试发送消息
执行 docker exec -it kafka /bin/bash 进入容器内部：
cd opt/kafka_2.12-2.2.0/
1、创建一个主题：
./bin/kafka-topics.sh --create --zookeeper 10.173.41.167:2181 --replication-factor 1 --partitions 1 --topic mykafka
2、运行一个消息生产者，指定topic为刚刚创建的主题:
./bin/kafka-console-producer.sh --broker-list 10.173.41.167:9092 --topic mykafka
3、新开一个ssh，进入相同目录，运行一个消费者，指定同样的主题：
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mykafka --from-beginning
4、接下来你就可以在生产者框中输入信息，在消费者框中就可以收到消息了
网友评论