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

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

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

View larger image

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

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

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