Uploaded image for project: 'AMQ Streams'
  1. AMQ Streams
  2. ENTMQST-5318

[KAFKA] Improve MirrorMaker logging in case of authorization errors

XMLWordPrintable

    • Icon: Story Story
    • Resolution: Done
    • Icon: Major Major
    • 2.8.0.GA, 2.9.0.GA
    • 2.5.0.GA
    • None
    • None
    • False
    • None
    • False

      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.

              Unassigned Unassigned
              rhn-support-aboucham Abel Bouchama
              Henrich Zrncik Henrich Zrncik
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: