C# .net core Confluent.Kafka Avro Deserialization

Question

I have an avro class generated using. avrogen -s customer-v1.avsc .

using Confluent.Kafka nuget package. I am able to serialize my CustomerAvro and send to Kafka Broker.

but I am having problem on deserializing because it is saying I don't have default deserializer being set.

can someone with expertise in this area be kind enough to give me a helping hand. Greatly Appreciated.

Answer 1

you need to specify a deserializer via the builder class. e.g.: https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/examples/AvroSpecific/Program.cs#L84