[KAFKA-9623] Streams will attempt to commit during shutdown if rebalance is in progress

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.6.0
• Component/s: streams
• Assignee: Guozhang Wang
• Reporter: Guozhang Wang
• Created: 28/Feb/20 01:30
• Updated: 28/Feb/20 22:20
• Resolved: 28/Feb/20 22:20

Description

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.

Issue Links

• links to: GitHub Pull Request #8190