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消息,并使用获取的模式将其映射到通用记录对象中。

相关内容

热门资讯

两分钟辅助!wepoker游戏... 两分钟辅助!wepoker游戏的安装教程,wepoker透视苹果系统,法子教程(确实有挂)1、这是跨...
七分钟辅助!德扑之心免费透视,... 七分钟辅助!德扑之心免费透视,wepoker私人辅助器,方案教程(有挂教学)1、德扑之心免费透视免费...
三分钟辅助!hhpoker可以... 三分钟辅助!hhpoker可以开挂吗,wepoker私人局透视教程,操作教程(有挂讲解)1、wepo...
4分钟辅助!wepoker辅助... 4分钟辅助!wepoker辅助工具,hhpoker透视方法,教程书教程(有挂教程)1、起透看视 we...
9分钟辅助!wepoker怎么... 9分钟辅助!wepoker怎么获得好牌,pokerworld破解版下载,练习教程(有挂分析)1、不需...
第九分钟辅助!拱趴大菠萝挂怎么... 第九分钟辅助!拱趴大菠萝挂怎么安装,pokemmo手机版脚本免费,机巧教程(有挂讲解)1、上手简单,...
九分钟辅助!德州来玩辅助器,w... 九分钟辅助!德州来玩辅助器,wejoker辅助器要钱玩吗,攻略教程(有挂讲解)1、首先打开wejok...
五分钟辅助!xpoker辅助工... 五分钟辅助!xpoker辅助工具,wepoker有透视功能吗,绝活教程(证实有挂)1、该软件可以轻松...
第6分钟辅助!德扑HHpoke... 第6分钟辅助!德扑HHpoker有挂吗,hardrock透视工具,方案教程(了解有挂)1、下载好德扑...
第7分钟辅助!wepoker可... 第7分钟辅助!wepoker可以开透视吗,epoker免费透视脚本,指南教程(有挂教学)1、首先打开...