7.2. 在 Service Registry 中查找模式的策略


Kafka 客户端序列化程序使用 lookup 策略 来确定在 Service Registry 中注册消息模式的工件 ID 和全局 ID。对于给定主题和消息,您可以使用 ArtifactReferenceResolverStrategy Java 接口的不同实现返回对 registry 中工件的引用。

每个策略的类都位于 io.apicurio.registry.serde.strategy 软件包中。Avro SerDes 的特定策略类位于 io.apicurio.registry.serde.avro.strategy 软件包中。默认策略是 TopicIdStrategy,它查找名称与 Kafka 主题接收信息相同的 Service Registry 工件。

示例

public ArtifactReference artifactReference(String topic, boolean isKey, T schema) {
        return ArtifactReference.builder()
                .groupId(null)
                .artifactId(String.format("%s-%s", topic, isKey ? "key" : "value"))
                .build();

  • topic 参数是收到消息的 Kafka 主题的名称。
  • 当消息键被序列化时,isKey 参数为 true,当消息值序列化时为 false
  • schema 参数是消息序列化或反序列化的 schema。
  • 返回的 ArtifactReference 包含 schema 注册的工件 ID。

您使用的查找策略取决于如何和在哪里存储您的架构。例如,如果您具有不同的 Kafka 主题与相同的 Avro 消息类型,您可以使用一个策略来使用 记录 ID

工件解析器策略

工件解析器策略提供了一种将 Kafka 主题和消息信息映射到 Service Registry 中的工件的方法。映射的常见惯例是,将 Kafka 主题名称与 键或 合并,具体取决于是否将序列化器用于 Kafka 消息键或值。

但是,您可以使用 Service Registry 提供的策略或创建一个实施 io.apicurio.registry.serde.strategy.ArtifactReferenceResolverStrategy 的自定义 Java 类来对映射使用替代约定。

返回对工件的引用的策略

Service Registry 提供以下策略,根据 ArtifactReferenceResolverStrategy 的实现返回对工件的引用:

RecordIdStrategy
使用 schema 全名的 Avro 具体策略。
TopicRecordIdStrategy
使用主题名称和架构全名的特定于 Avro 的策略。
TopicIdStrategy
默认策略,它使用主题名和 keyvalue 后缀。
SimpleTopicIdStrategy
仅使用主题名称的简单策略。

DefaultSchemaResolver 接口

默认架构解析器找到并标识工件解析器策略中提供的工件引用下注册的架构的特定版本。每个工件的每个版本都有一个全局唯一标识符,可用于检索该工件的内容。这个全局 ID 包含在每个 Kafka 信息中,以便反序列化器可以从 Apicurio Registry 正确获取 schema。

默认架构解析器可以查找现有的工件版本,或者可以根据使用哪个策略来注册该工件版本。您还可以创建实施 io.apicurio.registry.resolver.SchemaResolver 的自定义 Java 类来提供自己的策略。但是,建议您使用 DefaultSchemaResolver 并指定配置属性。

配置 registry 查找选项

使用 DefaultSchemaResolver 时,您可以使用应用程序属性配置其行为。下表显示了一些常用的示例:

表 7.1. Service Registry 查找配置选项
属性类型描述默认

apicurio.registry.find-latest

布尔值

指定序列化器是否在 registry 中查找相应组 ID 和工件 ID 的最新工件。

false

apicurio.registry.use-id

字符串

指示序列化器将指定的 ID 写入 Kafka,并指示反序列化器使用此 ID 查找模式。

None

apicurio.registry.auto-register

布尔值

指定序列化器是否在 registry 中创建工件。JSON 架构序列化器不支持此功能。

false

apicurio.registry.check-period-ms

字符串

指定以毫秒为单位缓存全局 ID 的时间。如果没有配置,则每次都会获取全局 ID。

None

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.