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 (将#修改为@）