玩一玩 GOlang 连接 kafka(单机)

2018年5月19日 作者 jacky

环境

kafka的安装
zookeeper的安装

第三方库准备

  1. 安装依赖库sarama

  1. sarama-cluster依赖库(如果你需要的是集群模式)

同步消费模式

异步消费模式

异步消息之Select

消费者

参考资料:https://blog.csdn.net/kdpujie/article/details/79093595