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

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.8.0
• Component/s: mirrormaker
• Assignee: Dmitry Werner
• Reporter: Mickael Maison
• Created: 28/Sep/23 12:29
• Updated: 16/Apr/24 10:09
• Resolved: 16/Apr/24 10:09

Description

In case MirrorMaker is missing DESCRIBE_CONFIGS on the source cluster, all youget in the logs are lines like:

2023-09-27 11:56:54,989 ERROR [my-cluster-source->my-cluster-target.MirrorSourceConnector|worker] Scheduler for MirrorSourceConnector caught exception in scheduled task: refreshing topics (org.apache.kafka.connect.mirror.Scheduler) [Scheduler for MirrorSourceConnector-refreshing topics]
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TopicAuthorizationException: Topic authorization failed.

It would be good to report the exact call that failed and include the cluster as well to make it easy to figure out which permissions are missing.

Issue Links

• links to: GitHub Pull Request #15558