kafka连接更新插件无需重新加载容器kafka连接
我想开发一个Kafka连接器，但为了快速测试，我想重新加载插件，而不是重新加载我的docker堆栈中的容器。有办法做到吗？
实际上，我编译了连接器，并将jar文件移动到绑定在容器kafka connect上的文件夹中。移动文件后，我重新加载容器。
先谢谢你。
共有1个答案
不可能“热插拔”插件；它们仅在Connect工作进程启动时扫描，在CLASSPATH也被扫描之后。
您应该使用单元/集成测试进行“快速测试”。如果这还不够，则可以使用连接独立而不是容器
-
我有一个现有的2个kafka服务器加载了mysql连接器。它起作用了。此外，我需要添加MongoDB连接器。我已经在我的Kafka服务器（Centos7）上安装了confluent schema registry，它可以工作，我停止/启动/重新启动，看起来没有什么问题。我在这里下载并提取了debezium Mongo插件/usr/连接器/插件/debezium连接器mongodb/ 我编辑了 /e
-
我尝试在连接群集中加载一个简单的 Kafka 连接器。我为连接器创建了jar，并将Kafka Connect作为docker启动。在日志中，我可以看到它正在加载插件。Docker 可以正确挂载 jar 文件。但是，在调用 http://localhost:8083/connector-plugins 时，我的自定义连接器不在列表中。 我简单地从这个repo:https://github.com/r
-
我正在尝试使用Debezium和kafka。我已经在属性中注册了一个包含3个表的连接器，并且它正常工作。下面是运行连接器的配置。 命令： 配置json： 这将成功执行，但当我列出Kafka主题时，只有最后3个主题出现，2个新的主题没有添加。
-
我正在windows计算机上使用Kafka，并尝试使用文件源连接器生成从文件到Kafka主题的内容。首先我启动了zookeeper，然后在启动Kafka Standalone Connector时启动了Kafka server（步骤3），我收到了很多警告，ReflectionsException 我对此没有什么疑问： 1。我需要添加一些jar文件吗 2。在libs文件夹下的Kafka dir中有一
-
我下载了aiven kafka connect jdbc并手动构建了jar。将同一个jar放在kafka connect插件目录中，并在connect-standalone.properties中提到插件路径。但当我运行connect时，它会抛出一个错误：“找不到任何实现连接器的类，并且名称与io.aivn.connect.JdbcSourceConnector匹配” 我的配置中缺少什么？ 连接-
-
在与docker和kafka的基础上磕磕绊绊，无法获得客户端连接 到目前为止我所做的 docker-机器活动，不返回活动主机 我的groovy类（从一个示例中剪切和粘贴，连接如下所示 当我运行这个init时，我得到的错误是它不能解析连接，因为java.io.ioException：不能解析地址:7BF9F9278E64:9092，这是内部容器端口。（我的脚本正在从我的普通IDE桌面环境中调用） 感