0

我正在尝试为我们的融合云安装 MQ 源和接收器连接器。我已经为本地 apache kafka 完成了此操作，但对云执行相同操作似乎有所不同。按照融合文档说我需要在我的本地安装一个平台，我这样做了，然后运行一个 confluent-hub 安装，它确实在我的本地安装连接器，然后将 json 用于分布式实例。我的问题是当我运行 json 时，它说找不到 mq 的类，我试图将 CLASSPATH 指向 jars 所在的目录，但仍然得到相同的错误。我如何成功运行它？

--
ERROR Uncaught exception in REST call to /connectors (org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper:61)
org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.confluent.connect.ibm.mq.IbmMQSourceConnector,

还想了解在本地安装连接器将如何应用于我的云集群？不知道我错过了什么！

4

1 回答 1

0

Confluent Cloud 不支持自定义连接器安装，我上次检查过。他们需要明确支持并提供它。

我假设您正在阅读一些文档，这些文档表明您需要运行自己的 Connect 集群（不一定在本地），您可以完全控制已安装的连接器

于 2021-10-17T13:11:13.900 回答