我想开发一个Kafka连接器,但为了快速测试,我想重新加载插件而不重新加载我的docker堆栈中的容器。有办法吗?
实际上我编译了连接器,并将jar文件移动到绑定在容器kafka connect上的文件夹中。移动文件后,重新加载容器。
提前感谢。
不支持" hot swap ";插件;它们只在Connect工作进程启动时扫描,在CLASSPATH也被扫描之后。
您应该使用单元/集成测试进行"快速测试"。如果这还不够,那么可以使用connect-standalone
而不是容器