1.6. 使用 schema 和 Java client serializers/deserializers 验证 Kafka 消息

Kafka producer 应用可以使用 serializers 对符合特定事件架构的消息进行编码。然后，Kafka 使用者应用程序可以使用反序列化者根据特定的模式 ID 来验证消息已被序列化。

图 1.2. Service Registry 和 Kafka 客户端架构

Service Registry 提供 Kafka 客户端 serializers/deserializers (SerDes)在运行时验证以下消息类型：

Service Registry Maven 存储库和源代码发行版本包括这些消息类型的 Kafka SerDes 实施，Kafka 客户端应用程序开发人员可以与 registry 集成。

这些实施包括用于每个支持的消息类型的自定义 Java 类，例如 io.apicurio.registry.serde.avro，客户端应用程序可以在运行时从 registry 中拉取 schema。