Kafka Connect:获取连接器配置
Kafka Connect: Getting connector configuration
我一直在测试kafka connect。但是对于每个连接器,我都必须阅读连接器文档以了解连接器所需的配置。据我阅读 kafka connect API 文档,我已经看到 APIs 以获取连接器相关数据。
GET /connector-plugins
- return Kafka Connect 集群中安装的连接器插件列表。请注意,API 仅检查处理请求的 worker 上的连接器,这意味着您可能会看到不一致的结果,尤其是在滚动升级期间,如果您添加新的连接器 jar。
PUT /connector-plugins/{connector-type}/config/validate
- 根据配置定义验证提供的配置值。此 API 执行每个配置验证,returns 建议值和验证期间的错误消息。
其余 API 与创建的连接器有关。有没有办法获得所需连接器的配置?
Is there anyway to get the configuration for the required connectors
验证端点正是这样做的,它是 Landoop Kafka Connect UI 用来为 missing/misconfigured 属性提供错误的。
属性如何成为必需的实现细节取决于连接器配置的 Importance
级别,对于任何非高重要性配置,最好参考文档或源代码(如果可用)
我一直在测试kafka connect。但是对于每个连接器,我都必须阅读连接器文档以了解连接器所需的配置。据我阅读 kafka connect API 文档,我已经看到 APIs 以获取连接器相关数据。
GET /connector-plugins
- return Kafka Connect 集群中安装的连接器插件列表。请注意,API 仅检查处理请求的 worker 上的连接器,这意味着您可能会看到不一致的结果,尤其是在滚动升级期间,如果您添加新的连接器 jar。
PUT /connector-plugins/{connector-type}/config/validate
- 根据配置定义验证提供的配置值。此 API 执行每个配置验证,returns 建议值和验证期间的错误消息。
其余 API 与创建的连接器有关。有没有办法获得所需连接器的配置?
Is there anyway to get the configuration for the required connectors
验证端点正是这样做的,它是 Landoop Kafka Connect UI 用来为 missing/misconfigured 属性提供错误的。
属性如何成为必需的实现细节取决于连接器配置的 Importance
级别,对于任何非高重要性配置,最好参考文档或源代码(如果可用)