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