1.6. 使用 schema 和 Java 客户端序列化器/反序列化器验证 Kafka 消息

Kafka 生成者应用程序可以使用 serializers 对符合特定事件模式的信息进行编码。然后，Kafka 消费者应用程序可以使用 deserializers 根据特定的模式 ID 验证消息已使用正确的模式序列化。

图 1.2. Apicurio Registry 和 Kafka 客户端 SerDes 架构

View larger image

Apicurio Registry 提供 Kafka 客户端序列化器/反序列化器(SerDes)来在运行时验证以下消息类型：

Apicurio Registry Maven 存储库和源代码分布包括这些消息类型的 Kafka SerDes 实现，Kafka 客户端应用程序开发人员可用于与 Apicurio Registry 集成。

这些实现包括每种支持的消息类型的自定义 Java 类，如 io.apicurio.registry.serde.avro，客户端应用程序可在运行时用于从 Apicurio Registry 中拉取模式进行验证。