nicktelford opened a new pull request, #17778: URL: https://github.com/apache/kafka/pull/17778
When we introduced "startup tasks" in #16922, we initialized them with no input partitions, because they aren't known until assignment. However, when we update them during assignment, it's possible that we update the topology with the incorrect source topics for some internal topics, due to a difference in the way internal topics are handled for StandbyTasks. To resolve this, we now initialize startup tasks with the correct input partitions, by calculating them from the Topology. When we assign our startup tasks, we now conditionally update their input partitions only if they've actually changed, just as we do for regular StandbyTasks. With this, the E2E tests now pass, as expected. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
