【问题标题】:Custom kafka connector is not detected未检测到自定义 kafka 连接器
【发布时间】:2022-08-16 21:43:10
【问题描述】:

我没有互联网访问权限,因此无法使用 Maven 构建或打包自定义 kafka 连接器。

我正在尝试插入自定义连接器,但它没有被添加到连接器列表中。我确信 PluginClassLoader 正在检测连接器路径,但它没有添加连接器。是否有任何文件夹结构或我需要遵循的任何内容,或者我必须在构建 jar 文件时指定任何参数。 下面是连接日志的图片

  • 你真的建立了一个JAR吗?还是您只是将类/java 文件放入某个文件夹中? Maven 不需要互联网来打包/编译代码,只需下载依赖项......我想指出 JMS 连接器已经存在
  • 我正在创建一个 tibco-jms 连接器,它在 confluent 上,但它需要 confluent 许可证,我们正在使用 cloudera kafka 设置。因此创建自定义连接器
  • 您是否将 Apache Camel 连接器视为替代方案?无论如何,你没有回答我剩下的问题。显然找到了该文件夹,但在其中没有找到实现 SourceConnector 接口的类

标签: java maven apache-kafka jar apache-kafka-connect


【解决方案1】:

发现问题实际上 jar 没有正确构建我在 META-INF 下创建了 INDEX.list 文件,其中提到了类路径

【讨论】:

    猜你喜欢
    • 2022-01-09
    • 2020-01-07
    • 2020-04-04
    • 2019-10-08
    • 1970-01-01
    • 2017-07-29
    • 1970-01-01
    • 2017-08-30
    • 2019-08-08
    相关资源
    最近更新 更多