Damian Guy created KAFKA-5702:
---------------------------------
Summary: Refactor StreamThread to separate concerns and enable
better testability
Key: KAFKA-5702
URL: https://issues.apache.org/jira/browse/KAFKA-5702
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Damian Guy
Assignee: Damian Guy
{{StreamThread}} does a lot of stuff, i.e., managing and creating tasks,
getting data from consumers, updating standby tasks, punctuating, rebalancing
etc. With the current design it is extremely hard to reason about and is quite
tightly coupled.
We need to start to tease out some of the separate concerns from StreamThread,
ie, TaskManager, RebalanceListener etc.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
