9.3. 使用者架构配置
消费者客户端应用程序使用一个反序列工具将所使用的消息从特定的代理主题获取到正确的数据格式。
要让消费者使用 Service Registry 进行反序列化,您需要:
- 定义模式并将其注册到 Service Registry
- Service Registry 的 URL
- 用于消息的 service Registry deserializer 服务
- 输入数据流以进行反序列化
然后,使用写入到被使用的消息中的全局 ID 来检索该架构。因此,收到的消息必须包含全局 ID 以及消息数据。
例如:
# ... [MAGIC_BYTE] [GLOBAL_ID] [MESSAGE DATA]
现在,当您启动 Kafka 和 Service Registry 时,您可以访问 schema,以便格式化从 Kafka 代理主题接收的信息。