8.2. Service Registry serializer/deserializer 配置属性
本节提供了 Service Registry Kafka 序列化器(SerDes)的 Java 配置属性的引用信息。
SchemaResolver 接口
Service Registry SerDes 基于 SchemaResolver
接口,它提取对 registry 的访问,并为所有支持的格式的 SerDes 类应用相同的查找逻辑。
常数 | 属性 | Description | 类型 | 默认 |
---|---|---|---|---|
|
|
供 serializers 和 deserializers 使用。实施 | 字符串 |
|
建议使用 DefaultSchemaResolver
,并为大多数用例提供有用的功能。对于某些高级用例,您可以使用 SchemaResolver
的自定义实现。
DefaultSchemaResolver 类
您可以使用 DefaultSchemaResolver
配置以下功能:
- 访问 registry API
- 如何查找 registry 中的工件
- 如何向 Kafka 写入和读取工件信息
- deserializers 的回退选项
配置 registry API 访问选项
DefaultSchemaResolver
提供以下属性来配置对核心 registry API 的访问:
常数 | 属性 | Description | 类型 | 默认 |
---|---|---|---|---|
|
| 供 serializers 和 deserializers 使用。用于访问 registry API 的 URL。 |
| 无 |
|
| 供 serializers 和 deserializers 使用。身份验证服务的 URL。在使用 OAuth 客户端凭证流访问安全 registry 时是必需的。 |
| 无 |
|
| 供 serializers 和 deserializers 使用。用于访问身份验证服务的 realm。在使用 OAuth 客户端凭证流访问安全 registry 时是必需的。 |
| 无 |
|
| 供 serializers 和 deserializers 使用。用于访问身份验证服务的客户端 ID。在使用 OAuth 客户端凭证流访问安全 registry 时是必需的。 |
| 无 |
|
| 供 serializers 和 deserializers 使用。用于访问身份验证服务的客户端机密。在使用 OAuth 客户端凭证流访问安全 registry 时是必需的。 |
| 无 |
|
| 供 serializers 和 deserializers 使用。访问 registry 的用户名。使用 HTTP 基本身份验证访问安全 registry 时是必需的。 |
| 无 |
|
| 供 serializers 和 deserializers 使用。用于访问 registry 的密码。使用 HTTP 基本身份验证访问安全 registry 时是必需的。 |
| 无 |
配置 registry 查找选项
DefaultSchemaResolver
使用以下属性来配置如何在 Service Registry 中查找工件。
常数 | 属性 | Description | 类型 | 默认 |
---|---|---|---|---|
|
|
仅供序列化商使用。实现 |
|
|
|
|
仅供序列化商使用。设置用于查询或创建工件的 |
| 无 |
|
|
仅供序列化商使用。设置用于查询或创建工件的 |
| 无 |
|
|
仅供序列化商使用。设置用于查询或创建工件的工件版本。覆盖 |
| 无 |
|
| 仅供序列化商使用。指定 serializer 是否在 registry 中查找对应组 ID 和工件 ID 的最新工件。 |
|
|
|
| 仅供序列化商使用。指定 serializer 试图在 registry 中创建工件。JSON Schema serializer 不支持此功能。 |
|
|
|
|
仅供序列化商使用。在存在冲突创建工件时,配置客户端的行为,因为工件已存在。可用值包括 |
|
|
|
| 供 serializers 和 deserializers 使用。指定在 auto-eviction 前缓存工件的时长。如果没有设置,则每次都会获取工件。 |
| 无 |
|
|
供 serializers 和 deserializers 使用。配置,以使用指定的 |
|
|
配置在 Kafka 中读/写 registry 工件
DefaultSchemaResolver
使用以下属性来配置工件信息是如何写入和从 Kafka 读取的。
常数 | 属性 | Description | 类型 | 默认 |
---|---|---|---|---|
|
| 供 serializers 和 deserializers 使用。配置 以读取/写入工件标识符到 Kafka 消息标头,而不是在消息有效负载中。 |
|
|
|
|
供 serializers 和 deserializers 使用。实现 |
|
|
|
|
供 serializers 和 deserializers 使用。实施 |
|
|
|
|
供 serializers 和 deserializers 使用。启用与 |
|
|
配置 deserializer fall-back 选项
DefaultSchemaResolver
使用以下属性为所有 deserializers 配置回退提供程序。
常数 | 属性 | Description | 类型 | 默认 |
---|---|---|---|---|
|
|
仅限由 deserializers 使用。设置 |
|
|
DefaultFallbackArtifactProvider
使用以下属性来配置 deserializer fall-back 选项:
常数 | 属性 | Description | 类型 | 默认 |
---|---|---|---|---|
|
|
仅供反序列化商使用。设置用于解析用于反序列化的工件的 |
| 无 |
|
|
仅供反序列化商使用。设置用于解析用于反序列化的组的 |
| 无 |
|
| 仅供反序列化商使用。设置用于解析用于反序列化的工件的版本。 |
| 无 |
其他资源
- 如需了解更多详细信息,请参阅 SerdeConfig Java 类
-
您可以将应用程序属性配置为 Java 系统属性,或者在 Quarkus
application.properties
文件中包含它们。如需了解更多详细信息,请参阅 Quarkus 文档。