You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/03/01 21:59:00 UTC

[jira] [Updated] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability

     [ https://issues.apache.org/jira/browse/KAFKA-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matthias J. Sax updated KAFKA-5702:
-----------------------------------
    Fix Version/s: 1.0.0

> 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
>            Priority: Major
>             Fix For: 1.0.0
>
>
> {{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
(v7.6.3#76005)