Kafka Connect：获取连接器配置

Question

我一直在用kafka connect进行测试。但对于每个连接器，我都必须去阅读连接器文档，以了解连接器所需的配置。据我阅读 kafka connect API 文档，我已经看到 API 来获取连接器相关数据。

GET /connector-plugins

- 返回 Kafka Connect 集群中安装的连接器插件列表。请注意，API 仅检查处理请求的工作线程上的连接器，这意味着您可能会看到不一致的结果，特别是在滚动升级期间，如果您添加新的连接器 jar。

PUT /connector-plugins/{connector-type}/config/validate

- 根据配置定义验证提供的配置值。此 API 执行每个配置验证，在验证期间返回建议值和错误消息。

其余其他API与创建的连接器相关。有没有办法获得所需连接器的配置？

Answer 1

是否有办法获取所需连接器的配置

验证端点正是这样做的，Landoop Kafka Connect UI 使用它来提供丢失/配置错误的属性的错误。

如何需要属性的实现细节取决于连接器配置的

Importance

级别，对于任何非高重要性配置，参考文档或源代码（如果有）将是最好的

Answer 2

这是一篇旧帖子，但可能仍然有人需要这个。

从版本 3.6 开始，有一种方法可以使用 REST API 获取插件的所有配置选项： GET /connector-plugins/< plugin >/config

遗憾的是，这不包括 PUT /connector-plugins/< plugin >/config/validate 端点中返回的推荐值。