docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka
docker run -d --name zookeeper --publish 2181:2181 --volume /etc/localtime:/etc/localtime wurstmeister/zookeeper
#下面的10.0.16.9替换为你的Linux机器公网IP的地址(不然KafkaTools工具连不到它)。
docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_ConNECT=zookeeper:2181 --env KAFKA_ADVERTISED_HOST_NAME=10.0.16.9 --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime wurstmeister/kafka
# ba2540992d9e为刚才返回的containerId
docker exec -it ba2540992d9e /bin/bash
第六步:进入容器里进行生产和消费消息(具体进入/opt/kafkaxxxx 要ls一下 查看自己拉取的哪个版本的镜像产生的容器)
cd /opt/kafka_2.13-2.8.1
创建一个主题名为netmusic:
bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic netmusic
使用KafkaTools连接
工具下载地址:Offset Explorer
切记,你的Linux机器要开放9092与2181端口!!!我的机器是轻量级应用服务器,所以要在网页中设置!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)