Description
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.
Attachments
Issue Links
- contains
-
KAFKA-5551 StreamThread should not expose methods for testing
-
- Resolved
-
- links to
