Kafka Connect 经常检查新连接器

Question

是否可以在Kafka Connect集群的指定插件路径下经常检查是否有新的connector直接上传？

我想要实现的是，每次在连接器 jar 中发生更改时，直接在 pod 内上传连接器 jar 文件，而无需重新创建图像和重新部署连接集群。我已经做了很多测试，我想通过避免每次更改时重新部署集群和重新创建映像来节省时间。

我正在尝试捕捉只能在实际集群而不是沙箱（本地 docker-compose 集群）上发生的场景。

Answer 1

如果您想使用新的连接器插件，您必须重新启动 Kafka Connect worker。

Answer 2

感谢您的回复。我最终在 kafka connect 集群中做了一个 init 容器，它从 artifactory 下载 jar 文件并将其存储在卷中。图像重建已被消除，因此我只需重新启动集群即可进行更改。