搜索

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

download PDF

Kafka 制作者应用程序可以使用序列化器来对符合特定事件模式的信息进行编码。然后,Kafka 消费者应用程序可以使用反序列化器来验证消息是否使用正确的模式来序列化信息,具体取决于特定的模式 ID。

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

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 进行验证。

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.