下载镜像
docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka
启动镜像
docker run -d --name zookeeper --p 2181:2181 -t wurstmeister/zookeeper
docker run -d --name kafka -p 9092:9092 --link zookeeper:zk --e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 --e KAFKA_ADVERTISED_HOST_NAME=localhost -e KAFKA_ADVERTISED_PORT=9092 -e HOST_IP=localhost -e KAFKA_BROKER_ID=1 -e ZK=zk -t wurstmeister/kafka
测试发送消息
docker ps
进入容器内部
docker exec it ${container_id} /bin/bash
进入kafka默认目录
cd opt/kafka_2.11-0.10.1.1/
创建主题
bin/kafka-topics.sh --creare --zookeeper zookeeper:2181 --replication-factor 1 --partition 1--topic mykafka
运行一个消息生产者,指定topic
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
打开一个新的ssh,进入相同的目录,运行一个消息消费者,指定topic
bin/kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic mykafka --form-beginning
测试发送消息
在生产者框中输入信息,在消费者框中可以接收消息