c# - 如何在 C# 中为泛型类型创建 Avro 模式？

Question

我正在使用 Kafka 和 Confluent's .NET client 开发 .NET Standard pub/sub 包.我的制作人有以下界面。

IEventPublisher.cs

public interface IEventPublisher<T>
{
    bool Publish(Event<T> evnt);
}

我的 KafkaEventPublisher<T>类实现了这个接口(interface)，并且正在发布的有效载荷 T 被包装在 Event<T> 中。信封。

Event.cs

public class Event<T>
{
    // Some other properties 

    public T Payload { get; set; }
}

我的组件的初始实现不使用 Avro 序列化程序或架构注册表。它序列化了 Event<T>使用 Newtonsoft.Json 到 JSON并将字符串生成到 Kafka 主题。这样做的好处是有效载荷实际上可以是任何对象。主题名称是对象的完全限定类名称，因此主题保证是同类的。缺点是有效载荷对 Kafka 是不透明的。

我现在正在从 Newtonsoft.Json 转换到 Avro 和架构注册表。这似乎表明我的模型不能再是任何东西了。它们必须专门编写以通过实现 ISpecificRecord 来允许 Avro 序列化。界面。如果这是真的，这并不理想，但我可以接受。

我似乎无法弄清楚的问题是如何合并 Event<T>封装到 Avro 模式中。有没有办法将模式嵌套在另一个模式中？我所有的具体模式是否也应该定义 Event<T>信封？使用 GenericRecord 是否明智？相反，并尝试在运行时使用反射自动生成模式，以便我的组件可以恢复接受任何对象作为有效负载？

Answer 1

也许有一种更优雅的方式，但在每个模式中包含正确的东西应该可以解决问题。也许您想以编程方式执行此操作以确保一致性。
一般来说，一切正常工作可能都很好，除非您发现自己试图检查每条消息并为每条消息定义架构。这可能是可能的，但肯定不是高性能/可取的。