1. 首页
  2. 数据库
  3. 其它
  4. golang kafka sarama 消费者组

golang kafka sarama 消费者组

上传者: 2021-02-01 15:51:06上传 PDF文件 33.56KB 热度 43次
之前用kafka,没在网上找到关于 sarama消费者组的代码。后来才在源码里面找到例子,现在稍微修改了下代码,记录一下。 package main import ( context github.com/Shopify/sarama log github.com/sirupsen/logrus os os/signal sync syscall time ) type Kafka struct { brokers []string topics []string //OffsetNewest int64 = -1 //OffsetO
用户评论