sarama包
-
Golang里读写kafka消息队列的简单用法
本文主要记录利用kafka来作为订阅模式消息队列的简单使用方法，kafka环境是在本地使用docker起的两个容器，启动方法如下：// 创建网络 docker network create app-tier --driver bridge // 启动zookeeper docker run -d --name zookeeper-server \ &...
本文主要记录利用kafka来作为订阅模式消息队列的简单使用方法，kafka环境是在本地使用docker起的两个容器，启动方法如下：// 创建网络 docker network create app-tier --driver bridge // 启动zookeeper docker run -d --name zookeeper-server \ &...