Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

mimaison merged PR #15558: URL: https://github.com/apache/kafka/pull/15558 -- 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:

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

mimaison commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1559584216 ## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java: ## @@ -320,4 +323,21 @@ static void createCompactedTopic(String topicName, short

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

wernerdv commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1544403086 ## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java: ## @@ -216,7 +217,10 @@ Set findConsumerGroups() Collection

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

mimaison commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1544383751 ## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java: ## @@ -216,7 +217,10 @@ Set findConsumerGroups() Collection

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

wernerdv commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1544364748 ## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java: ## @@ -320,4 +322,19 @@ static void createCompactedTopic(String topicName, short

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

wernerdv commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1544364893 ## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java: ## @@ -216,7 +217,10 @@ Set findConsumerGroups() Collection

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

mimaison commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1540866456 ## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java: ## @@ -320,4 +322,19 @@ static void createCompactedTopic(String topicName, short

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

wernerdv commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1534499279 ## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java: ## @@ -630,8 +631,16 @@ Map describeTopicConfigs(Set topics) Set

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

wernerdv commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1534494595 ## connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java: ## @@ -224,6 +229,39 @@ public void testNoBrokerAclAuthorizer() throws

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

mimaison commented on code in PR #15558: URL: https://github.com/apache/kafka/pull/15558#discussion_r1532418821 ## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java: ## @@ -630,8 +631,16 @@ Map describeTopicConfigs(Set topics) Set

Re: [PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

wernerdv commented on PR #15558: URL: https://github.com/apache/kafka/pull/15558#issuecomment-2007211486 Hello, @mimaison Please, take a look. -- 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

[PR] KAFKA-15517: Improve MirrorMaker logging in case of authorization errors [kafka]

wernerdv opened a new pull request, #15558: URL: https://github.com/apache/kafka/pull/15558 Log the list of topics for which an authorization error has been received when try to describe configs, along with the cluster alias. ### Committer Checklist (excluded from commit message)