1.6. 使用 Kafka 客户端 serializers/deserializers 验证模式

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

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

View larger image

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

Apicurio Registry Maven 存储库和源代码发行版本包括用于这些消息类型的 Kafka SerDe 实施，Kafka 客户端开发人员可以与 registry 集成。这些实施包括用于每个支持的消息类型的自定义 Java 类，例如 io.apicurio.registry.serde.avro，客户端应用程序可以在运行时从 registry 中拉取 schema。