我正在运行kafka kubenetes helm部署,但是我不确定如何安装自定义插件。
在本地版本的kafka上运行自定义插件时,我会挂载卷 /myplugin
,然后设置plugin path环境变量。
我不确定如何将此工作流应用于helm charts/kubernetes部署,主要是如何将插件安装到kafka connect pod,以便在默认的 plugin.path=/usr/share/java
.
我正在运行kafka kubenetes helm部署,但是我不确定如何安装自定义插件。
在本地版本的kafka上运行自定义插件时,我会挂载卷 /myplugin
,然后设置plugin path环境变量。
我不确定如何将此工作流应用于helm charts/kubernetes部署,主要是如何将插件安装到kafka connect pod,以便在默认的 plugin.path=/usr/share/java
.
1条答案
按热度按时间6pp0gazn1#
看一下本书的最后几张幻灯片https://talks.rmoff.net/qz5nss/from-zero-to-hero-with-kafka-connect. 你可以挂载你的插件,但最好的方法是要么建立一个新的形象,以扩展插件
cp-kafka-connect-base
,或在运行时安装插件-都使用confluent hub。