Re: enable.auto.commit semantics

2019-02-03 Thread Pere Urbón Bayes
Hi, from the confluent docs, > Offset Management: The two main settings affecting offset management are whether auto-commit is enabled and the offset reset policy. First, if you set enable.auto.commit (which is the default), then the consumer will automatically commit offsets periodically at the

enable.auto.commit semantics

2019-01-31 Thread Peter Levart
Hello, I'm using Java KafkaConsumer and I'm wondering what is the guarantee of consuming messages when enable.auto.commit is set to true. What is the earliest time the offsets of messages returned from last poll() may be committed? Immediately after returning from poll() or upon next call to