KafkaConnect:如何在现有的KafkaConnectDocker安装中添加自定义连接器(SMT)



我有一个Kafka Connect集群,它有JDBC源连接器插件。我也有自己的自定义SMT,这是一个jar文件,用于处理我使用JDBC源连接器插件的用例,例如my-custom-1.0.0.jar。例如下面的。transformer类型是我自己的java类MySMT

"transforms": "mytransformer", 
"transforms.mytransformer.type": "com.my.MySMT"

我知道我可以把jar文件放在plugin.path中。但是,在不重新启动Kafka Connect集群的情况下,是否可以重新加载连接器插件(JDBC源连接器(来加载我的SMT jar?

如果不是这样,最好的做法是什么?

谢谢。

插件不是动态加载的,因此您需要重新启动工作程序

另一种选择是尽可能保持源连接器数据的原始状态,然后使用流处理器将其操作为消费者可以使用的格式

最新更新