是否可以经常检查是否有新的连接器直接上传到Kafka集群的指定插件路径中?
我想要实现的是,每次在连接器jar中发生更改时,都可以直接将连接器jar文件上传到吊舱内,而不需要重新创建映像并重新部署connect集群。我已经做了很多测试,我想要节省时间,避免重新部署集群,并在每次更改时重新创建映像。
我试图捕捉只能发生在实际集群上的场景,而不是沙箱(本地停靠-组合集群)。
发布于 2020-11-13 09:24:14
如果你想拿起新的连接器插件,你必须重新启动卡夫卡连接工人。
发布于 2020-12-04 13:01:31
谢谢你的回复。最后,我在kafka集群中创建了一个init容器,该集群从工件下载jar文件并将其存储在卷中。图像重建已经消除,所以我只需重新启动集群进行更改。
https://stackoverflow.com/questions/64817671
复制相似问题