【发布时间】:2021-06-03 20:10:00
【问题描述】:
我一直在用 kafka connect 进行测试。但是对于每个连接器,我必须阅读连接器文档以了解连接器所需的配置。就我阅读 kafka 连接 API 文档而言,我已经看到了 API 以获取连接器相关数据。
GET /connector-plugins - 返回安装在 Kafka Connect 集群中的连接器插件列表。请注意,API 仅检查处理请求的工作器上的连接器,这意味着您可能会看到不一致的结果,尤其是在滚动升级期间,如果您添加了新的连接器 jar。
PUT /connector-plugins/{connector-type}/config/validate - 根据配置定义验证提供的配置值。此 API 执行每个配置验证,在验证期间返回建议值和错误消息。
其他 API 与创建的连接器相关。有没有办法获得所需连接器的配置?
【问题讨论】:
标签: apache-kafka apache-kafka-connect