1.4.1. Kafka客户端：sarama¶

文档 [1] 源码 [2]

关于offset:

1. sarama.OffsetOldest
2. sarama.OffsetNewest

只有这2个选项, 如果你执行了session.MarkMessage(msg)
则client重启后不管你用哪个选项, 只从mark的offset的下一点开始
如想从最新or最老的开始读取可以使用新的groudId解决

主页

索引

模块索引

搜索页面