第 7 章 在 Java 客户端中使用序列化器/反序列化器验证 Kafka 信息

Service Registry 将模式管理与客户端应用程序配置分离。您可以通过在客户端代码中指定 URL 来启用 Java 客户端应用程序使用来自 Service Registry 的 schema。

您可以在 Service Registry 中存储模式以序列化和反序列化消息，这些消息从客户端应用程序引用，以确保它们发送和接收的消息与这些模式兼容。Kafka 客户端应用程序可以在运行时从 Service Registry 中推送或拉取其模式。

模式可以演进，您可以在 Service Registry 中定义规则，例如，确保架构更改有效，且不会破坏应用程序使用的早期版本。Service Registry 通过将修改的模式与以前的模式进行比较来检查兼容性。

Service Registry 模式技术

Service Registry 为 schema 技术提供模式 registry 支持，例如：

客户端应用程序可通过 Service Registry 提供的 Kafka 客户端序列化器(SerDes)服务使用这些模式技术。Service Registry 提供的 SerDes 类的成熟度和使用可能会有所不同。以下章节提供有关每个 schema 类型的更多详情。

producer 模式配置

制作者客户端应用程序使用序列化器将它发送到特定代理主题的消息放在正确的数据格式中。

启用制作者以使用 Service Registry 进行序列化：

注册 schema 后，当启动 Kafka 和 Service Registry 时，您可以访问 schema 来格式化由制作者发送到 Kafka 代理主题的信息。或者，根据配置，生成者可以在第一次使用时自动注册 schema。

如果 schema 已存在，您可以根据 Service Registry 中定义的兼容性规则，使用 registry REST API 创建新版本。版本用于兼容性检查，作为 schema 的演进。组 ID、工件 ID 和 version 代表用于标识 schema 的唯一元组。

consumer 模式配置

消费者客户端应用程序使用反序列化器将来自特定代理主题的消息获取到正确的数据格式。

启用消费者使用 Service Registry 进行反序列化：

当在消息有效负载中查找全局 ID 时，数据格式以 magic 字节开头，用作消费者的信号，后跟全局 ID，以及消息数据正常。例如：

...

# ...
[MAGIC_BYTE]
[GLOBAL_ID]
[MESSAGE DATA]

然后，当启动 Kafka 和 Service Registry 时，您可以访问模式来格式化从 Kafka 代理主题接收的消息。

内容 ID 不唯一标识版本，而是仅唯一标识版本内容。如果多个版本共享相同的内容，它们具有不同的全局 ID，但具有相同的内容 ID。confluent Schema Registry 默认使用内容 ID。