[KAFKA-3157] Mirror maker doesn't commit offset with new consumer when there is no more messages

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.0.0
• Fix Version/s: 0.9.0.1
• Assignee: TAO XIAO
• Reporter: TAO XIAO
• Created: 27/Jan/16 09:45
• Updated: 05/Feb/16 17:11
• Resolved: 05/Feb/16 17:11

Description

Mirror maker doesn't commit messages with new consumer enabled when messages are sent to source within the time range that is smaller than commit interval and no more messages are sent afterwards.

The steps to reproduce:

1. Start mirror maker.
2. The default commit interval is 1 min. Send message for less than 1 min for example 10 seconds.
3. Don't send more messages.
4. Check committed offset with group command. The lag remains unchanged for ever even though the messages have been sent to destination.