kafka连接商店配置在哪里



当我在kafka Connect中创建源或接收器连接器时,它在哪里保存与该连接器相关的设置?我可以浏览文件吗?我们计划创建50多个连接器,在某一时刻我们需要将它们从一个环境复制到另一个环境,我想知道是否有一种简单的方法。

kafka在分布式模式下连接使用kafka主题来存储配置。

kafka Connect支持REST API。您可以将其用于查看现有的连接器配置,创建新的连接器(包括编程/自动适用于50多个新连接器(,启动/停止连接器等。

这里记录了REST API。

kafka Connect分布式模式是从属性文件开始的。该属性文件定义了" config主题","值是一个常规的kafka主题,其中这些上传的连接器定义被存储。

如果要将连接器配置加载到不同的环境中,建议您将JSON文件保存到磁盘而不是直接上传,或者使用Terraform(例如Terraform或Ansable(来管理许多连接器的外部工具。

最新更新