【发布时间】: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