1.6. 使用 schema 和 Java client serializers/deserializers 验证 Kafka 消息
Kafka producer 应用程序可以使用序列化器对符合特定事件 schema 的消息进行编码。然后，Kafka 使用者应用程序可以使用反序列化器验证消息已使用正确的模式序列化，具体取决于特定的模式 ID。
图 1.2. Service Registry 和 Kafka 客户端架构
Service Registry 提供 Kafka 客户端序列化rs/deserializers(SerDes)来在运行时验证以下消息类型：
- Apache Avro
- Google 协议缓冲
- JSON 架构
Service Registry Maven 存储库和源代码发行版本包括这些消息类型的 Kafka SerDes 实施，Kafka 客户端应用程序开发人员可以与 registry 集成。
这些实施包括每个支持的消息类型的自定义 Java 类，如 io.apicurio.registry.serde.avro，客户端应用程序在运行时用于从 registry 中拉取 schema 进行验证。
