是否可以从源连接器中获取已注册的架构?我在模式注册表中注册了一个静态模式,需要从连接器获取该模式并将其传递给 SourceRecord。
我使用 CachedSchemaRegistryClient 使用模式 id 获取模式,但它返回了 Avro 模式。所以我必须将其转换为 org.apache.kafka.connect.data.Schema。请就此提供一些指示。
或者连接器中的任何其他方式,我可以在不使用 CachedSchemaRegistryClient 的情况下直接执行相同操作?
谢谢你,斯里吉斯