未授权访问远程群集中的kafka connect内部主题

byqmnocz  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(364)

我正在尝试在机器a中设置kafka jdbc接收器连接器,其中我必须连接到远程机器b中的kafka主题。我通过ssl证书尝试了生产者和消费者,并在机器a中运行良好。现在,我尝试通过相同的ssl证书在机器a中创建jdbc接收器连接器,但得到以下错误。我已经在connect分布式文件中给出了生产者、消费者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.]

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题