Kafka connect更新插件,无需重新加载容器Kafka connect



我想开发一个Kafka连接器,但为了快速测试,我想重新加载插件而不重新加载我的docker堆栈中的容器。有办法吗?

实际上我编译了连接器,并将jar文件移动到绑定在容器kafka connect上的文件夹中。移动文件后,重新加载容器。

提前感谢。

不支持" hot swap ";插件;它们只在Connect工作进程启动时扫描,在CLASSPATH也被扫描之后。

您应该使用单元/集成测试进行"快速测试"。如果这还不够,那么可以使用connect-standalone而不是容器

最新更新