Docker 安装kafka 单机版本

一、安装Zookeeper

下载zookeeper镜像

docker pull wurstmeister/zookeeper

启动zookeeper

docker run -d --name zookeeper --publish 2181:2181 --volume /etc/localtime:/etc/localtime wurstmeister/zookeeper

二、安装Kafka

下载kafka镜像，这里我选择2.11-0.11.0.3的版本

docker pull wurstmeister/kafka:2.11-0.11.0.3

启动kafka
KAFKA_ZOOKEEPER_CONNECT配置本地的ES的地址，KAFKA_ADVERTISED_HOST_NAME配置kafka所在服务器的地址，这里我都是本机IP

//启动kafka
docker run -d --name kafka --publish 9092:9092 \
--link zookeeper \
--env KAFKA_ZOOKEEPER_CONNECT=10.137.85.170:2181 \
--env KAFKA_ADVERTISED_HOST_NAME=10.137.85.170 \
--env KAFKA_ADVERTISED_PORT=9092  \
--volume /etc/localtime:/etc/localtime \
wurstmeister/kafka:2.11-0.11.0.3

测试
进入容器

docker exec -it kafka bash

kafka默认安装在/opt/kafka

cd opt/kafka

创建topic

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

查看topic

bin/kafka-topics.sh --list --zookeeper 10.137.85.170:2181

查看topic

创建生产者
bin/kafka-console-producer.sh --broker-list 10.137.85.170:9092 --topic mykafka 

创建消费者

bin/kafka-console-consumer.sh --zookeeper 10.137.85.170:2181 --topic mykafka --from-beginning