Gwen Shapira created KAFKA-3056:
-----------------------------------
Summary: MirrorMaker with new consumer doesn't handle
CommitFailedException
Key: KAFKA-3056
URL: https://issues.apache.org/jira/browse/KAFKA-3056
Project: Kafka
Issue Type: Bug
Reporter: Gwen Shapira
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
