AWSGlue模式注册表反序列化器无法读取AVRO消息
创始人
2024-09-25 15:31:55
0

在使用AWS Glue模式注册表反序列化器时,需要确保使用正确的模式来反序列化AVRO消息。可以通过使用AWS SDK for Java中的SchemaRegistryClient对象从注册表获取模式,并将其传递给反序列化器。以下是示例代码:

//获取模式
SchemaRegistryClient schemaRegistryClient = new AwsGlueSchemaRegistryClientBuilder()
        .withGlueRegion(region)
        .withCredentialProvider(credentialProvider)
        .build();

SchemaRegistryConfiguration schemaRegistryConfiguration = new SchemaRegistryConfiguration(schemaRegistryClient);

String schemaArn = "arn:aws:glue:region:account-id:schema/db_name/table_name";
Schema schema = schemaRegistryConfiguration.getSchema(schemaArn);

//反序列化消息
byte[] avroMessage = ... ;
Deserializer deserializer = new AwsGlueSchemaRegistryDeserializer();
deserializer.configure(Collections.singletonMap(AwsGlueSchemaRegistryDeserializer.AWS_GLUE_SCHEMA_REGISTRY_CONFIG, schemaRegistryConfiguration), false);

GenericRecord record = (GenericRecord) deserializer.deserialize(avroMessage, schema);

在此示例中,我们首先使用AWS Glue模式注册表客户端获取模式。然后,我们创建一个SchemaRegistryConfiguration对象,将客户端传递给它,并将其用作反序列化器的配置。最后,我们从字节数组反序列化AVRO消息,并使用获取的模式将其映射到通用记录对象中。

相关内容

热门资讯

透视辅助!德州透视是真的吗,p... 透视辅助!德州透视是真的吗,pokemmo手机版脚本,阶段教程(果然存在有挂)-哔哩哔哩透视辅助!德...
透视辅助器!aapoker辅助... 透视辅助器!aapoker辅助器是真的吗(透视)开挂辅助app(都是真的是有挂)-哔哩哔哩1、玩家可...
透视好牌!wpk透视辅助方法,... 透视好牌!wpk透视辅助方法,wepoker提高好牌率,手筋教程(果然真的是有挂)-哔哩哔哩1、we...
透视测试!pokemmo脚本辅... 透视测试!pokemmo脚本辅助器(透视)开挂辅助插件(原来是有挂)-哔哩哔哩一、pokemmo脚本...
透视黑科技!wpk私人局有透视... 透视黑科技!wpk私人局有透视吗,wepoker透视辅助下载,教材教程(其实是有挂)-哔哩哔哩wep...
透视机制!wepoker辅助器... 透视机制!wepoker辅助器安装包(透视)开挂辅助神器(本来有挂)-哔哩哔哩暗藏猫腻,小编详细说明...
透视计算!wepoker游戏下... 透视计算!wepoker游戏下载,hhpoker可以控制牌吗,举措教程(真是是有挂)-哔哩哔哩1、h...
透视安卓版本!wepoker有... 您好,wepoker有插件吗这款游戏可以开挂的,确实是有挂的,需要了解加去威信【136704302】...
透视规律!wepoker网页版... 透视规律!wepoker网页版透视方法,hhpoker免费透视脚本,指引教程(一贯是真的挂)-哔哩哔...
透视计算器!hhpoker到底... 透视计算器!hhpoker到底可以辅助吗(透视)开挂辅助器(都是有挂)-哔哩哔哩1、hhpoker到...