docker 安装kafka

为了方便,直接用docker安装kafka进行开发环境.

1.首先下载镜像

ps:鉴于国内的环境,建议先设置docker国内镜像.

这里使用了wurstmeister/kafkawurstmeister/zookeeper这两个版本的镜像

docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka

2.创建启动镜像

先启动zookeeper:

docker run -d –name zookeeper –publish 2181:2181 \
–volume /etc/localtime:/etc/localtime \
zookeeper:latest

zookeeper启动完成后再启动kafka:

docker run -d –name kafka –publish 9092:9092 \
–link zookeeper \
–env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
–env KAFKA_ADVERTISED_HOST_NAME=docker机器的IP \
–env KAFKA_ADVERTISED_PORT=9092 \
–volume /etc/localtime:/etc/localtime \
wurstmeister/kafka:latest

3. 测试消息

进入kafka容器

docker exec -it kafka /bin/bash

进入kafka目录-这里的版本号可能能升级

cd /opt/kafka_2.12-1.0.0

创建主题:

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

运行消息 生产者

bin/kafka-console-producer.sh –broker-list localhost:9092 –topic mykafka

然后输入一些信息
运行消息 消费者

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

发表评论

电子邮件地址不会被公开。 必填项已用*标注