将自定义连接器安装到Kafka Connect上的Kubernetes上



我正在运行kafka kubenetes头盔部署,但是我不确定如何安装自定义插件。

在我本地版本的kafka上运行自定义插件时,我将卷/myplugin安装到docker映像,然后设置插件路径环境变量。

我不确定如何将此工作流程应用于Helm Charts/Kubernetes部署,主要是如何将插件安装到Kafka Connect Pod中,以便可以在默认的plugin.path=/usr/share/java中找到。

可以查看https://talks.rmoff.net/qz5nss/from-zero-wero-to-hero-wero-with-kafka-connect的最后几个幻灯片。您可以安装插件,但最好的方法是构建一个新图像以扩展cp-kafka-connect-base,或在运行时安装插件 - 都使用Contruent Hub。

最新更新