[KAFKA-10577] StreamThread should be able to process any processible tasks regardless of its state

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Assignee: Unassigned
• Reporter: Guozhang Wang
• Created: 06/Oct/20 05:21
• Updated: 06/Oct/20 05:37

Description

After KAFKA-10199 is done, we should allow active tasks processing even if we are not yet in RUNNING. More generally speaking, we would no longer rely on the thread's RUNNING state to start processing any tasks, but would just always process any processible tasks.