第 8 章 在 Java 客户端中配置 Kafka serializers/deserializers
本章详细介绍了如何在生成者和消费者 Java 客户端应用程序中配置 Kafka serializers/deserializers (SerDes)：
先决条件
8.1. 在客户端应用程序中的 Service Registry serializer/deserializer 配置
您可以使用本节中显示的示例常量直接在客户端应用中配置特定的客户端序列化器/反序列化器(SerDes)服务和模式查找策略。另外，您可以在文件或实例中配置对应的 Service Registry 应用程序属性。
以下小节展示了常用的 SerDes constants 和 configuration options 的示例。
配置 SerDes 服务
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 SerDes 服务兼容。例如，将默认 ID 格式从
Long改为Integer支持 Confluent ID 格式。 -
简化 Confluent ID 的处理。如果设置为
true，则使用Integer用于全局 ID 查找。设置不应与ID_HANDLER选项一起使用。
其他资源
- 有关配置选项的详情，请查看 第 8.2 节 “Service Registry serializer/deserializer 配置属性”
配置 SerDes 查找策略
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
...其他资源
- 有关查找策略的详情，请查看 第 7 章 在 Java 客户端中使用序列化器/反序列化器验证 Kafka 信息
- 有关配置选项的详情，请查看 第 8.2 节 “Service Registry serializer/deserializer 配置属性”
配置 Kafka 转换器
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 转换所需的序列化器。
- 用于 Service Registry Kafka 转换所需的反序列化器。
其他资源
- 如需了解更多详细信息，请参阅 SerdeBasedConverter Java 类
配置不同模式类型
有关如何为不同的模式技术配置 SerDes 的详情，请参考：
