这是在此主题中提出问题的C#代码。
可以通过以下代码行检索模式，然后将其转换为Avro模式。
GetSchemaRegistry().GetLatestSchemaAsync("SchemaRegistrySubject").Result.Schema
-----------------------------------------------------------------
使用Avro.IO;
使用Avro.Specific;
使用Confluent.Kafka;
public class KafkaAvroSerializer<T> : IAsyncSerializer<T>
where T : class, ISpecificRecord
{
    public Task<byte[]> SerializeAsync(T data, SerializationContext context)
    {
        return Task.Run(() =>
        {
            using (var ms = new MemoryStream())
            {
                var enc = new BinaryEncoder(ms);
                var writer = new SpecificDefaultWriter(data.Schema);
                writer.Write(data, enc);
                return ms.ToArray();
            }
        });
    }
}
-------------------------------------------------------------------------------
使用Avro;
使用Avro.Specific;
public class MyRecord : ISpecificRecord
{
    public Schema Schema =>
    Schema.Parse(@"
    {
        ""name"": ""name"",
        ""namespace"": ""namespace"",
        ""type"": ""record"",
        ""fields"": [
            {
                ""name"": ""field1"",
                ""type"": [
                    ""null"",
                    ""int""
                ],
                ""default"": null
            },
            {
                ""name"": ""field2"",
                ""type"": [
                    ""null"",
                    ""string""
                ],
                ""default"": null
            },
            {
                ""name"": ""field3"",
                ""type"": [
                    ""null"",
                    ""string""
                ],
                ""default"": null
            }
        ]
    }");
    public int field1 { get; set; }
    public string field2 { get; set; }
    public string field3 { get; set; }
    public object Get(int fieldPos)
    {
        switch (fieldPos)
        {
            case 0: return field1;
            case 1: return field2;
            case 2: return field3;
            default: throw new AvroRuntimeException("在Get()中的无效索引：" + fieldPos);
        };
    }
    public void Put(int fieldPos, object fieldValue)
    {
        switch (fieldPos)
        {
            case 0: field1 = (int)fieldValue; break;
            case 1: field2 = (string)fieldValue; break;
            case 2: field3 = (string)fieldValue; break;
            default: throw new AvroRuntimeException("在Put()中的无效索引：" + fieldPos);
        };
    }
}
------------------------------------------------------------------------------
使用Confluent.Kafka;
使用Confluent.SchemaRegistry;
public async Task Publish<T>(T @event) where T
{
    using (var producer = GetProducer())
    {
        try
        {
            if (@event == null)
            {
                return;
            }
            var kafkaEvent = KafkaEventFactory.Create(@event);
            var avroModel = AvroModelFactory.Create(kafkaEvent);
            var message = new Message<string, MyRecord>() { Value = avroModel, Key = kafkaEvent.Key };
            var deliveryResult = await producer.ProduceAsync(_kafkaOption.Topic, message);
            _logger.LogInformation($"已交付 '{deliveryResult.Value}' 到 '{deliveryResult.TopicPartitionOffset}'");
        }
        catch (ProduceException<string, MyRecord> e)
        {
            _logger.LogError($"交付失败：{e.Error.Reason}");
            throw;
        }
    }
}
private IProducer<string, MyRecord> GetProducer()
{
    var config = GetProducerConfig();
    var schemaRegistry = GetSchemaRegistry();
    var producer = new ProducerBuilder<string, MyRecord >(config)
        .SetErrorHandler((_, error) =>
        {
            _logger.LogError(error.ToString());
        })
        .SetValueSerializer(new KafkaAvroSerializer< MyRecord >())
        .Build();
    return producer;
}
private ProducerConfig GetProducerConfig()
{
    return new ProducerConfig
    {
        BootstrapServers = "BootstrapServers"
    };
}
private CachedSchemaRegistryClient GetSchemaRegistry()
{
    return new CachedSchemaRegistryClient(new SchemaRegistryConfig { Url = "SchemaRegistryUrl" });
}