Boyang Chen created KAFKA-9112: ---------------------------------- Summary: Combine streams `onAssignment` with `partitionsAssigned` task creation Key: KAFKA-9112 URL: https://issues.apache.org/jira/browse/KAFKA-9112 Project: Kafka Issue Type: Improvement Reporter: Boyang Chen
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)