confluent-kafka-go icon indicating copy to clipboard operation
confluent-kafka-go copied to clipboard

Published 20 hours ago • verified publisher icon confluentinc

Consumer close behaviour

Open shubhang93 opened this issue 2 years ago • 1 comments

Will calling the conusmer.Close method commit the stored offsets before closing the consumer ? I am using the consumer.StoreOffsets to manually store offsets, but I have enabled the auto commit timer with an interval of 5s.

shubhang93 avatar Apr 21 '22 13:04 shubhang93

yes.

marking this issue as enhancement because the docstring for this client doesn't state that.

mhowlett avatar Apr 26 '22 14:04 mhowlett