smjn opened a new pull request, #23656: URL: https://github.com/apache/kafka/pull/23656
ShareGroupDLQStateManager.validateDlqTopic() checked topic existence (and whether auto-create is enabled) only after delegating to ShareGroupDLQValidator.validateDlqTopicConfig(). Since the prefix-compliance check inside validateDlqTopicConfig has no existence guard, a DLQ topic that was both missing and non-compliant with the required prefix was reported as a prefix mismatch instead of the more actionable "does not exist" error. Move the existence/auto-create check ahead of the delegation, so it is evaluated first; validateDlqTopicConfig itself is unchanged and remains a pure config-only check (naming, enablement, prefix). -- 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]
