THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
In that sense the consumer's offsets auto-commits should be turned off, and the offsets will be committed after a future associated with a message is received.
Whether message handler will be added is still under discussion.
Offset commit thread
The offsets commit thread should execute periodically. Because the consumer offset is committed per SourcePartition/ConsumerGroup. A Map[TopicPartition, UnackedOffsetList] will be needed to track the offsets that is ready for commit.
...