第 8 章 在 Java 客户端中配置 Kafka serializers/deserializers
本章详细介绍了如何在您的制作者和消费者 Java 客户端应用程序中配置 Kafka SerD：
- 第 8.1 节 “在客户端应用程序中，服务 Registry serializer/deserializer 配置”
- 第 8.2 节 “Service Registry serializer/deserializer 配置属性”
- 第 8.3 节 “如何配置不同的客户端序列化r/deserializer 类型”
- 第 8.3.1 节 “使用 Service Registry 配置 Avro SerDes”
- 第 8.3.2 节 “使用 Service Registry 配置 JSON Schema SerDes”
- 第 8.3.3 节 “使用 Service Registry 配置 Protobuf SerDes”
8.1. 在客户端应用程序中，服务 Registry serializer/deserializer 配置
您可以使用本节中的示例常量在客户端应用程序中直接配置特定的客户端序列化/反序列化器(SerDe)服务和架构查找策略。另外，您还可以在文件或实例中配置对应的 Service Registry 应用程序属性。
以下小节显示了常用的 SerDe constants 和 配置选项示例。
配置 SerDe 服务
public class SerdeConfig {
public static final String REGISTRY_URL = "apicurio.registry.url"; 1
public static final String ID_HANDLER = "apicurio.registry.id-handler"; 2
public static final String ENABLE_CONFLUENT_ID_HANDLER = "apicurio.registry.as-confluent"; 3- Service Registry 所需 URL。
-
扩展 ID 处理以支持其他 ID 格式，并使其与 Service Registry SerDe 服务兼容。例如，将默认 ID 格式从
Long改为Integer支持 Confluent ID 格式。 -
简化 Confluent ID 的处理。如果设置为
true，则使用Integer用于全局 ID 查找。此设置不应与ID_HANDLER选项一起使用。
其他资源
- 有关配置选项的详情，请查看 第 8.2 节 “Service Registry serializer/deserializer 配置属性”
配置 SerDe 查找策略
public class SerdeConfig {
public static final String ARTIFACT_RESOLVER_STRATEGY = "apicurio.registry.artifact-resolver-strategy"; 1
public static final String SCHEMA_RESOLVER = "apicurio.registry.schema-resolver"; 2
...- 实现工件解析器策略的 Java 类，并在 Kafka SerDe 和工件 ID 之间映射。默认为主题 ID 策略。这仅由 serializer 类使用。
-
实现 schema 解析器的 Java 类。默认为
DefaultSchemaResolver。这被 serializer 和 deserializer 类使用。
其他资源
- 有关查找策略的详情，请查看 第 7 章 在 Java 客户端中使用 serializers/deserializers 验证 Kafka 信息
- 有关配置选项的详情，请查看 第 8.2 节 “Service Registry serializer/deserializer 配置属性”
配置 Kafka converters
public class SerdeBasedConverter<S, T> extends SchemaResolverConfigurer<S, T> implements Converter, Closeable {
public static final String REGISTRY_CONVERTER_SERIALIZER_PARAM = "apicurio.registry.converter.serializer"; 1
public static final String REGISTRY_CONVERTER_DESERIALIZER_PARAM = "apicurio.registry.converter.deserializer"; 2- 与 Service Registry Kafka converter 搭配使用所需的序列化器。
- 与 Service Registry Kafka converter 搭配使用所需的 deserializer。
其他资源
- 如需了解更多详细信息，请参阅基于 SerdedeConverter Java 类
配置不同的模式类型
有关如何为不同的模式技术配置 SerDe 的详情，请查看以下操作：
