开发者社区> 问答> 正文

C#反序列化avro 400 请求报错 

//Define the schema in JSON
            const string Schema = @"{
            uot;"type"":{""type"" : ""map&ot;",""values"" :""string""}
            
            //Create a generic serializer based on the schema
            var serializer = AvroSerializer.CreateGeneric(Schema);
            var rootSchema = serializer.WriterSchema as RecordSchema;

            MemoryStream stream = new MemoryStream(bt);

            //dynamic actual = serializer.Deserialize(stream);

            using (var reader = AvroContainer.CreateGenericReader(stream))
            {
                while (reader.MoveNext())
                {
                    foreach (dynamic record in reader.Current.Objects)
                    {
                        //var sequenceNumber = record.SequenceNumber;
                        var headerText = System.Text.Encoding.UTF8.GetString(record.headers);
                        Console.WriteLine($"{headerText}");
                    }
                }
            }
在C#反序列化avro如上代码格式,在var reader = AvroContainer.CreateGenericReader(stream)处会报错“Invalid Avro object container in a stream. The header cannot be recognized” 不知道有没碰到过这种问题的?

展开
收起
kun坤 2020-05-28 16:08:45 694 0
1 条回答
写回答
取消 提交回答
  • 问题已经解决!

    2020-05-29 13:07:41
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载