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