我一直在测试卡夫卡的连接。但是对于每个连接器,我必须去阅读连接器文档,以了解连接器所需的配置。就我阅读的kafka文档而言,我看到了API来获取连接器相关的数据。
GET /connector-plugins -返回安装在Kafka集群中的连接器插件列表。请注意,API只检查处理请求的工作人员上的连接器,这意味着您可能会看到不一致的结果,特别是在滚动升级期间,如果您添加了新的连接器jars。
PUT /connector-plugins/{connector-type}/config/validate -根据配置定义验证提供的配置值。此API执行每个配置验证,在验证期间返回建议的值和错误消息。
其他API与创建的连接器相关。是否需要获得所需连接器的配置?
发布于 2021-03-20 14:46:46
无论如何,
都是为了获得所需连接器的配置。
验证端点正是这样做的,而Landoop就是用来为丢失/配置错误的属性提供错误的。
属性的实现细节取决于连接器配置的Importance级别,对于任何非高重要性的信任,参考文档或源代码(如果可用的话)将是最好的。
https://stackoverflow.com/questions/66487567
复制相似问题