如何解决Avro.avroexception:genericrecord 需要针对记录模式写入,但找到了 avro.generic.genericrecord
我从融合的卡夫卡制作人那里得到了例外
Avro.AvroException: GenericRecord 需要针对记录架构写入但找到 Avro.Generic.GenericRecord \n 在 Avro.Generic.DefaultWriter.EnsureRecordobject(RecordSchema s,Object value) \n 在 Avro.Generic.DefaultWriter.WriteRecord(RecordSchema 架构,对象值,编码器编码器) \n 在 Avro.Generic.DefaultWriter.Write(Schema schema,Object value,Encoder encoder) \n 在 Avro.Generic.DefaultWriter.WriteArray(ArraySchema schema,Encoder encoder) \n 在 Avro.Generic.DefaultWriter.Write(Schema schema,Encoder encoder) \n 在 Avro.Generic.DefaultWriter.WriteRecord(RecordSchema schema,Encoder encoder)
Schema: var s = (RecordSchema)RecordSchema.Parse( @{ "name": "StaticDatanotification","type": "record","namespace": "KafkaName","fields": [ { "name": "UniqueID","type": "string" },{ "name": "DataList","type": { "type": "array","items":{ "name": "DataList_record","type":"record","fields": [ { "name": "FieldName","type": "string" },{ "name": "OldValue","type": "string" } ] } } } ] } var child = (RecordSchema)RecordSchema.Parse( @{ "name": "DataList_record","type": "string" } ] }
C# 代码:
var recordStaticData = new GenericRecord(s);
recordStaticData.Add("UniqueID","123456");
List<GenericRecord> genericRecords = new List<GenericRecord>();
for (int i = 0; i < 3; i++)
{
GenericRecord StaticList = new GenericRecord(child);
StaticList.Add("FieldName","Name");
StaticList.Add("OldValue",i.ToString());
genericRecords.Add(StaticList);
}
recordStaticData.Add("DataList",genericRecords.ToArray());
var dr = producer.ProduceAsync("Topic",new Message<string,GenericRecord>{ Key = System.Guid.NewGuid().ToString("N"),Value = recordStaticData });
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。