1.6. 使用 schemas 和 Java 客户端序列化器/反序列化器验证 Kafka 消息
Kafka 生成者应用程序可以使用序列化器来编码符合特定事件模式的消息。然后，Kafka 消费者应用程序可以使用 deserializers 来验证信息是否根据特定的模式 ID 序列化。
图 1.2. Service Registry 和 Kafka 客户端 SerDes 架构
Service Registry 提供 Kafka 客户端序列化器/反序列化器(SerDes)，以便在运行时验证以下消息类型：
- Apache Avro
- Google Protobuf
- JSON Schema
Service Registry Maven 存储库和源代码分布包括这些消息类型的 Kafka SerDes 实现，Kafka 客户端应用程序开发人员可以使用它们与 Service Registry 集成。
这些实现包括每个支持的消息类型的自定义 Java 类，如 io.apicurio.registry.serde.avro，客户端应用程序可在运行时从 Service Registry 中拉取模式进行验证。
