c# - C# .net core Confluent.Kafka Avro 反序列化

Question

我有一个使用生成的 avro 类。avrogen -s 客户-v1.avsc 。

使用 Confluent.Kafka nuget 包。我能够序列化我的 CustomerAvro 并发送到 Kafka Broker。

但我在反序列化时遇到问题，因为它说我没有设置默认反序列化器。

有这方面专业知识的人可以帮我一把吗？非常感激。

标签： c#apache-kafkaavroconfluent-schema-registryconfluent-platform

Answer 1

您需要通过构建器类指定反序列化器。例如：https ://github.com/confluentinc/confluent-kafka-dotnet/blob/master/examples/AvroSpecific/Program.cs#L84