欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 财经 > 金融 > Docker 安装 Zookeeper + Kafka 保姆级教程

Docker 安装 Zookeeper + Kafka 保姆级教程

2025/2/24 0:34:23 来源:https://blog.csdn.net/weixin_43874535/article/details/141563988  浏览:    关键词:Docker 安装 Zookeeper + Kafka 保姆级教程

1.创建 docker-compose.yml

创建一个名为 docker-compose.yml 的文件,并添加以下内容:

version: '3.6'services:zookeeper:image: zookeeper:3.6container_name: zookeeperports:- "2181:2181"networks:- kafka-networkenvironment:ZOO_STANDALONE_ENABLED: "true"kafka:image: bitnami/kafka:3.6container_name: kafkadepends_on:- zookeeperports:- "9092:9092"environment:KAFKA_ADVERTISED_LISTENERS: INSIDE://kafka:9092,OUTSIDE://localhost:9092KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT,OUTSIDE:PLAINTEXTKAFKA_LISTENERS: INSIDE://0.0.0.0:9092,OUTSIDE://0.0.0.0:9093KAFKA_LISTENER_NAME: INSIDEKAFKA_ZOOKEEPER_CONNECT: zookeeper:2181KAFKA_INTER_BROKER_LISTENER_NAME: INSIDEnetworks:- kafka-networknetworks:kafka-network:driver: bridge

2.启动服务

运行以下命令来启动 Zookeeper 和 Kafka 服务:

docker compose -f docker-compose.yml up -d

此处会拉取镜像 耐心等待…

3.验证

3.1检查 Zookeeper 和 Kafka 容器是否正常运行:

docker ps

在这里插入图片描述

3.2通过 docker-compose logs 查看服务的日志,确保没有错误:

docker compose logs

3.3使用 docker exec 进入容器,并测试它们之间的连接:

docker exec -it kafka bash
curl http://zookeeper:2181
docker exec -it zookeeper bash
curl http://kafka:9092

4.测试数据

docker exec -it kafka bash

在Kafka容器创建主题:

kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --bootstrap-server kafka:9092

执行创建生产者命令:

kafka-console-producer.sh --broker-list localhost:9092 --topic test

在这里插入图片描述

在新的终端窗口中 再次进入Kafka容器 执行创建消费者命令:

docker exec -it kafka bash
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

在这里插入图片描述

如看到消息 代表成功

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com

热搜词