Confluent Avro Deserializer (KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro/ConfluentAvroDeserializer.cs)

KafkaFlow message deserializer using Confluent Schema Registry and Apache Avro. Use when consuming schema-validated Avro messages from Kafka.

// Source: https://github.com/Farfetch/kafkaflow | License: MIT | Copyright 2020 Farfetch
// Provided via justclaw.it.com; keep this notice with the code.
using System;
using System.IO;
using System.Threading.Tasks;
using Confluent.SchemaRegistry;
using Confluent.SchemaRegistry.Serdes;

namespace KafkaFlow.Serializer.SchemaRegistry;

/// <summary>
/// A message serializer using Apache.Avro library
/// </summary>
public class ConfluentAvroDeserializer : IDeserializer
{
    private readonly ISchemaRegistryClient _schemaRegistryClient;

    /// <summary>
    /// Initializes a new instance of the <see cref="ConfluentAvroDeserializer"/> class.
    /// </summary>
    /// <param name="resolver">The <see cref="IDependencyResolver"/> to be used by the framework</param>
    public ConfluentAvroDese

... (truncated -- full source via MCP)