Click here to Skip to main content
15,884,628 members
Please Sign up or sign in to vote.
0.00/5 (No votes)
See more:
I got the exception from confluent Kafka producer like
 Avro.AvroException: GenericRecord required to write against record schema but found Avro.Generic.GenericRecord
\n   at Avro.Generic.DefaultWriter.EnsureRecordObject(RecordSchema s, Object value)
\n   at Avro.Generic.DefaultWriter.WriteRecord(RecordSchema schema, Object value, Encoder encoder)
\n   at Avro.Generic.DefaultWriter.Write(Schema schema, Object value, Encoder encoder)
\n   at Avro.Generic.DefaultWriter.WriteArray(ArraySchema schema, Object value, Encoder encoder)
\n   at Avro.Generic.DefaultWriter.Write(Schema schema, Object value, Encoder encoder)
\n   at Avro.Generic.DefaultWriter.WriteRecord(RecordSchema schema, Object value, Encoder encoder)


please find the implementation code.

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":"record",
          "fields": [
            {
              "name": "FieldName","type": "string"
            },
            {
              "name": "OldValue","type": "string"
            }
          ]
        }


C# Implementation

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 });



What I have tried:

I found this solution from google. But its not suit this problem,

Avro.AvroException: GenericRecord required to write against record schema but found Avro.Generic.GenericRecord · Issue #1217 · confluentinc/confluent-kafka-dotnet · GitHub[^]
Posted

This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)



CodeProject, 20 Bay Street, 11th Floor Toronto, Ontario, Canada M5J 2N8 +1 (416) 849-8900