小编J S*_*J S的帖子

我有一个基于 Kafka 构建的事件源应用程序。目前我有一个包含多种消息类型的主题。全部使用 JSON 序列化/反序列化。

confluent 的架构注册表看起来是一种很好的消息类型维护方法，并且在 Avro 完全兼容模式下，它还为我的事件源应用程序中的消息版本控制提供了一种机制。

使用最近的补丁 -博客文章到 4.1.1 汇合。您可以使用 Avro 序列化器/反序列化器在一个主题中包含多种不同类型的消息。

但是，我还没有看到任何工作示例。甚至一个都没有。

我的问题是：在不必使用 Avro 联合​​类型（将所有不同类型的消息放在一个单一模式中并利用联合）的情况下，上述补丁真的有效吗？

这种方法如何与需要指定 Key 和 Value Serde 的 Kafka Streaming 应用程序一起使用？

我应该忘记 Avro 而是使用 protobuff 吗？