search

bsm / sarama-cluster

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]
MIT License
1.01k stars 222 forks source link

auto commit #288

Closed matzew closed 5 years ago

matzew commented 5 years ago

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 5 years ago

Ale you marking offsets after consuming messages?