[KAFKA-3056] MirrorMaker with new consumer doesn't handle CommitFailedException

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Assignee: Unassigned
• Reporter: Gwen Shapira
• Created: 02/Jan/16 01:31
• Updated: 15/Jun/17 20:26
• Resolved: 15/Jun/17 20:26

Description

MirrorMaker currently doesn't handle CommitFailedException when trying to commit (it only handles WakeupException).

I didn't test, but it appears that if MirrorMaker tries to commit while rebalancing is in progress, it will result in thread failure. Probably not what we want. I think the right thing is to log a message and call poll() again to trigger a re-join.

Issue Links

• duplicates: KAFKA-3409 Mirror maker hangs indefinitely due to commit