docker 配置 kafka+zookeeper,golang接入示例

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了docker 配置 kafka+zookeeper,golang接入示例相关的知识,希望对你有一定的参考价值。

参考技术A 配置zookeeper 使用kafka/bin/下自带的zk

运行 报错 卒。配置低了

docker-compose.yml

报错

换云搬瓦工的机器试一下

但是docker ps -a 发现只有zookeeper启动了,kafka失败, 检查日志 发现kafka运行需要java环境,而且对内存有要求,搬瓦工的vps不足够

因此修改docker-compose.yml 加入以下

stop 再启动

完美

测试
进入容器

查看已经建好的topic (docker-compose.yml)

发送消息

接收消息

接下来是golang接入kafka了

运行

以上是关于docker 配置 kafka+zookeeper,golang接入示例的主要内容,如果未能解决你的问题,请参考以下文章

我的 kafka docker 容器无法连接到我的 zookeeper docker 容器

docker下部署kafka集群(多个broker+多个zookeeper)

docker-compose 搭建 kafka 集群

Docker 安装 kafka

kafka docker 安装

kafka docker 安装