消息中心想要使用kafka作为消息中间件,测试阶段使用docker部署一个kafka,部署kafka首先要部署zookeeper,下面是快速部署的步骤
kafka
首先下载镜像,默认下载最新版本,可以自选
docker pull wurstmeister/kafka docker pull wurstmeister/zookeeper
启动zookeeper
docker run -d -p 2181:2181 --name some-zookeeper --restart always wurstmeister/zookeeper
启动kafka
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.1.116:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.1.116:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime wurstmeister/kafka
docker ps
如上就显示启动成功了
测试
# 首先进入kafka容器 docker exec -it kafka bash
进入安装目录
cd /opt/kafka_2.13-2.8.1
创建topic
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test