Kafka Streams stuck rebalancing after exception thrown in rebalance listener
Author: Matthias J. Sax
Reviewers: Ismael Juma, Eno Thereska, Guozhang Wang
Closes from mjsax/kafka-5073
@@ -570,6 +570,10 @@ public class StreamThread extends Thread {
resetInvalidOffsets(e);
}
+ if (rebalanceException != null) {
+ throw new StreamsException(logPrefix + " Failed to rebalance.", rebalanceException);
+ }
+
return records;
}
