[ 
https://issues.apache.org/jira/browse/KAFKA-3056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Dustin Cote resolved KAFKA-3056.
--------------------------------
    Resolution: Duplicate

> 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.4.14#64029)

Reply via email to