Hi Kafka Team,

What is expected behavior when you close *ConsumerConnector* and auto
commit is on ?  Basically, when auto commit interval is set to 5 seconds
and shutdown is called (before 5 seconds elapses) does ConsumerConnector
commit the offset of message consumed by (next()) method or consumer will
get duplicate messages when it comes online after restart ?

ConsumerConnector.shutdown();

Thanks,

Bhavesh

Reply via email to