Does KafkaConsumer::close() always commit offsets?

[pantoss]

Do I understand KafkaConsumer::close() documentation correctly? If it is called it will commit the consumer group offsets even if we have auto.commit.enable = false? My quick scan of the code wasn't able to answer the question for me.

What I'm observing which I cannot explain is if I throw an exception my program seems to be updating the offsets of the group even though I haven't called KafkaConsumer::commitSync or KafkaConsumer ::commitAsync yet and I have enable.auto.commit = false . The one thing I did notice is that I call KafkaConsumer::close() as the stack is unwound. Could this be the explanation?

Also if this is the case if I first call KafkaConsumer::unsubscribe() before the close, will this prevent the offsets from being committed?

Thanks,
Stefan

[pantoss]

Reading it again I guess to means if you have any commitAsync calls pending completion it will wait. I don't suppose anyone else has any idea. I've not been able to reliably recreate it which makes putting together a simple example rather difficult.