在连接器中手动注册Avro模式。
示例代码:
在连接器中手动注册Avro模式的示例代码如下:
SchemaRegistryClient schemaRegistryClient = new CachedSchemaRegistryClient(schemaRegistryUrl, 10);
schemaRegistryClient.register("my-schema", schema);
在这个例子中,我们使用CachedSchemaRegistryClient手动将名为'my-schema”的Avro模式注册到模式注册表中,然后再将其用于反序列化操作。这种方法能够绕过自动注册机制,确保正确地反序列化Avro模式。
下一篇:Avro模式无效