欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Docker 安装kafka 单机版本

程序员文章站 2022-07-13 10:09:32
...

一、安装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