auto commit
matzew opened this issue · 1 comments
matzew commented
Hi,
when having this cfg:
kafkaConfig := cluster.NewConfig()
kafkaConfig.Consumer.Return.Errors = true
kafkaConfig.Consumer.Offsets.Initial = sarama.OffsetOldest
//kafkaConfig.Consumer.Offsets.CommitInterval = 10 * time.Second
kafkaConfig.Group.Return.Notifications = true
and not calling consumer.MarkOffset(msg, "")
I do not see auto commit happing.... am I missing something ?
dim commented
Ale you marking offsets after consuming messages?