Joker-5 opened a new pull request, #19632: URL: https://github.com/apache/kafka/pull/19632
In https://github.com/apache/kafka/pull/15968/files, we changed the authorization logic slightly. If a produce request includes a topic name that doesn't exist and is not authorized, it now returns an UNKNOWN_TOPIC_OR_PARTITION error. Since topic name is sensitive information, it should return a TOPIC_AUTHORIZATION_FAILED error as before that PR. else if (!metadataCache.contains(topicPartition)) nonExistingTopicResponses += new TopicIdPartition(topicId, topicPartition) -> new PartitionResponse(Errors.UNKNOWN_TOPIC_OR_PARTITION) -- 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