[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Boyang Chen updated KAFKA-9112: ------------------------------- Component/s: streams > Combine streams `onAssignment` with `partitionsAssigned` task creation > ---------------------------------------------------------------------- > > Key: KAFKA-9112 > URL: https://issues.apache.org/jira/browse/KAFKA-9112 > Project: Kafka > Issue Type: Improvement > Components: streams > Reporter: Boyang Chen > Priority: Major > > Task manager needs to call `createTasks` inside partitionsAssigned callback, > which is after the `onAssignment` callback for assignor. This means during > task creation we rely on the status change based on the intermediate data > structures populated by a different callback, which is hard to reason about. > We should consider consolidate logics to either one of the callbacks, prefer > `onAssignment` as it contains full information needed. -- This message was sent by Atlassian Jira (v8.3.4#803005)