kamalcph opened a new pull request, #14755: URL: https://github.com/apache/kafka/pull/14755
When a node starts (or) restarts, then we send a _CREATE_TOPICS_ request to the controller to create the internal ___remote_log_metadata_ topic if it doesn't exist. Topic creation event is costly and handled by the controller. During re-balance, the controller can have pending requests in its queue and can lead to CREATE_TOPICS timeout. Instead of firing the _CREATE_TOPICS_ request when a node restarts, send a _METADATA_ request (topic describe) which is handled by the least loaded node before sending a request to create the topic. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
