Guozhang Wang created KAFKA-9623: ------------------------------------ Summary: Streams will attempt to commit during shutdown if rebalance is in progress Key: KAFKA-9623 URL: https://issues.apache.org/jira/browse/KAFKA-9623 Project: Kafka Issue Type: Bug Components: streams Reporter: Guozhang Wang Assignee: Guozhang Wang
This will throw a retriable `RebalanceInProgressException` which Streams does not currently expect. A possible fix is to change the condition of while(isRunning()) inside runLoop to sth. like isRunning() || !taskManager.rebalanceInProgress(), and within an iteration after we’ve added the records we will check isRunning() again and if false we would skip processing any records anyways. -- This message was sent by Atlassian Jira (v8.3.4#803005)