ssl - 无权访问远程集群中的 Kafka Connect 内部主题
问题描述
我正在尝试在机器 A 中设置 kafka jdbc sink 连接器,其中我必须连接到远程机器 B 中的 kafka 主题。我已经通过 ssl 证书尝试了生产者和消费者,并且在机器 A 上运行良好。现在我正在尝试通过相同的 SSL 证书在机器 A 中创建 jdbc sink 连接器,但出现以下错误。我在连接分布式文件中给出了生产者、消费者 SSL 配置属性。错误中的主题是在机器 B(远程)中创建的内部连接主题。
如果我错过任何事情以及如何解决它,请建议我。
org.apache.kafka.connect.errors.ConnectException: Error while attempting to create/find topic(s) 'connect-offset-storage-topic'
at org.apache.kafka.connect.util.TopicAdmin.createTopics(TopicAdmin.java:255)
at org.apache.kafka.connect.storage.KafkaOffsetBackingStore$1.run(KafkaOffsetBackingStore.java:99)
at org.apache.kafka.connect.util.KafkaBasedLog.start(KafkaBasedLog.java:126)
at org.apache.kafka.connect.storage.KafkaOffsetBackingStore.start(KafkaOffsetBackingStore.java:109)
at org.apache.kafka.connect.runtime.Worker.start(Worker.java:174)
at org.apache.kafka.connect.runtime.AbstractHerder.startServices(AbstractHerder.java:109)
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:215)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Topic authorization failed.]
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:262)
at org.apache.kafka.connect.util.TopicAdmin.createTopics(TopicAdmin.java:228)
... 11 more
Caused by: org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Topic authorization failed.]
解决方案
推荐阅读
- javascript - 有没有办法在单击某个链接时自动打开选项卡?
- javascript - 如何制作一个完整的可选择的?
- c - 动态分配的多维数组
- sql - 关于Oracle SQL的优化(分组)
- android-studio - android profiler 如何查看调用图表
- java - QueryDSL fetch 加入没有 groupby 的请求 GROUP BY
- python - 从字符串中删除重复的字母
- node.js - 如何使用 Bluebird 承诺修复“分页中未定义的响应”(@google-cloud)
- javascript - Firebase/数据库 + 径向 Btn + JS
- python - 在 Python/Selenium 中创建登录和注销循环