sollhui opened a new pull request, #66089: URL: https://github.com/apache/doris/pull/66089
Problem Summary: Kafka routine load metadata requests selected backend nodes from all compute groups, so partition and offset requests could be sent outside the compute group bound to the job. Solution: Pass the routine load job's persisted compute group to KafkaUtil and restrict both normal selection and blacklist fallback to backend nodes in that compute group. Preserve the existing global selection behavior for non-cloud deployments. Tests: - Add KafkaUtilTest coverage for compute-group-scoped backend selection. - Update routine load tests for compute group propagation and the KafkaUtil API change. -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
