auto commit

[matzew]

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]

Ale you marking offsets after consuming messages?