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

Kafka 客户端 serializer 使用 lookup 策略来 决定在 Apicurio Registry 中注册消息 schema 的工件 ID 和全局 ID。对于给定主题和消息，您可以使用 ArtifactReferenceResolverStrategy Java 接口的不同实现来返回对 registry 中的工件的引用。

每个策略的类位于 io.apicurio.registry.serde.strategy 软件包中。Avro SerDes 的特定策略类位于 io.apicurio.registry.serde.avro.strategy 软件包中。默认策略是 TopicIdStrategy，它查找与 Kafka 主题接收信息相同的 Apicurio 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();

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

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

工件解析器策略

工件解析器策略提供了一种将 Kafka 主题和消息信息映射到 Apicurio Registry 中的工件的方法。映射的常见约定是将 Kafka 主题名称与 键或 值 组合，具体取决于 serializer 是否用于 Kafka 消息键或值。

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

返回工件引用的策略

Apicurio Registry 提供以下策略，以根据 ArtifactReferenceResolverStrategy 的实现返回对工件的引用：

DefaultSchemaResolver 接口

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

默认架构解析器可以查找现有工件版本，如果未找到，则可以注册一个，具体取决于使用了哪个策略。您还可以通过创建一个实现 io.apicurio.registry.resolver.SchemaResolver 的自定义 Java 类来提供自己的策略。但是，建议使用 DefaultSchemaResolver 并指定配置属性。

配置 registry 查找选项

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