Docker 部署kafka_docker kafka

环境准备

• CentOS 7.5
• Docker 环境

zookeeper安装

• 下载zookeeper镜像

docker pull wurstmeister/zookeeper
1

• 启动zookeeper容器

docker run -d  --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper
1

参数说明：

-v /etc/localtime:/etc/localtime :让容器使用和服务器同样的时间设置
1

kafka 安装

• 下载镜像

docker pull wurstmeister/kafka
1

• 启动kafka镜像

docker run -d --name kafka -p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=39.108.99.163:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://39.108.99.163:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
-v /etc/localtime:/etc/localtime \
wurstmeister/kafka
1
2
3
4
5
6
7

参数说明：

-e KAFKA_BROKER_ID=0  在kafka集群中，每个kafka都有一个BROKER_ID来区分自己
-e KAFKA_ZOOKEEPER_CONNECT=39.108.99.163:2181    配置zookeeper管理kafka的路径
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://39.108.99.163:9092  把kafka的地址端口注册给zookeeper
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092  配置kafka的监听端口
-v /etc/localtime:/etc/localtime 让容器使用和服务器同样的时间设置
1
2
3
4
5

• 查看是否运行成功

docker ps 
1

启动成功了！

创建topic测试

• 创建一个topic

#进入容器6ae1e49888b3（CONTAINER ID）
docker exec -it 6ae1e49888b3 /bin/bash
#进入到bin目录
cd /opt/kafka/bin/
#创建一个topic（单机方式）
./kafka-topics.sh --create --zookeeper 39.108.99.163:2181 --replication-factor 1 --partitions 1 --topic mykafka
1
2
3
4
5
6

命令运行如下：

修改成自己启动时的ip,就可以创建成功了！

• 生产者/消费者

#生产者
./kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
#消费者
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mykafka --from-beginning
1
2
3
4