Hey,
I think I have found something.
My guess is that when the AbstactCoordinator.maybeLeaveGroup(...)
function's pollNoWakeUp part throws an exception, then it can not call
resetGeneration() and the HearBeatThread stays in STABLE state. The broker
won't be notified about the consumer's leave requ
Hi Guys,
I have just started to work on this ticket a little more than a week ago:
https://issues.apache.org/jira/browse/KAFKA-5138
I could not reproduce it sadly, but from the logs Dustin gave and from the
code it seems like this might not be just a MirrorMaker issue but a
consumer one.
My theo
[
https://issues.apache.org/jira/browse/KAFKA-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-5138:
---
Labels: newbie (was: )
> MirrorMaker doesn't exit on send failure occasionally
>
Dustin Cote created KAFKA-5138:
--
Summary: MirrorMaker doesn't exit on send failure occasionally
Key: KAFKA-5138
URL: https://issues.apache.org/jira/browse/KAFKA-5138
Project: Kafka
Issue Type: B
