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