[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sophie Blee-Goldman resolved KAFKA-9112. ---------------------------------------- Fix Version/s: 2.6.0 Assignee: Guozhang Wang Resolution: Fixed Think this issue was addressed as part of "The Refactor" > 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 > Assignee: Guozhang Wang > Priority: Major > Fix For: 2.6.0 > > > 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)