0

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

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

或者连接器中的任何其他方式,我可以在不使用 CachedSchemaRegistryClient 的情况下直接执行相同操作?

谢谢你,斯里吉斯

4

1 回答 1

0

您可以对模式注册表进行休息调用以进行查找。然而,这是一个非常不标准的连接器使用。在转换器中进行这种查找可能会更好。

于 2016-10-01T17:14:43.697 回答