通过ID /主题获取已注册的模式连接器

Question

是否可以从源连接器中获取已注册的模式？我有一个在模式注册表中注册的静态模式，需要从连接器获取该模式并将其传递给SourceRecord。

我使用CachedSchemaRegistryClient获取使用模式ID的模式，但它返回了Avro模式。所以我必须将其转换为org.apache.kafka.connect.data.Schema。请提供一些指示。

或者连接器中的任何其他方式，我可以使用CachedSchemaRegistryClient直接执行相同的操作？

谢谢你， Sreejith

Answer 1

你可以做一个REST调用到架构注册表做查找。然而，这是一个非常不标准的连接器使用。在转换器中进行这种查找可能会更好。