Re: [jira] [Updated] (KAFKA-3772) MirrorMaker crashes on Corrupted Message

2016-06-01 Thread Gerard Klijs
Just had a look at the code, as I would like some way to prevent such a scenario happening to us. It seems you can't prevent the mirror maker from exiting. In the 0.10 mirror maker, any exception which is not an ConsumerTimeoutException, or an WakeupException, will cause the whole mirror maker to

[jira] [Updated] (KAFKA-3772) MirrorMaker crashes on Corrupted Message

2016-05-31 Thread James Ranson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Ranson updated KAFKA-3772: Description: We recently came across an issue where a message on our source kafka cluster became