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

Question

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

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

我不确定如何将此工作流程应用于 helm Charts/kubernetes 部署，主要是如何将插件安装到 Kafka Connect pod，以便可以在 default 中找到它plugin.path=/usr/share/java。

Answer 1

看一下https://talks.rmoff.net/QZ5nsS/from-zero-to-hero-with-kafka-connect的最后几张幻灯片。您可以安装插件，但最好的方法是构建一个新映像来扩展cp-kafka-connect-base，或者在运行时安装插件 - 两者都使用 Confluence Hub。