应该使用 Kafka Schema Registry 服务器
Should use Kafka Schema Registry server
当我使用模式注册表服务器时,我发现我无法再更改同一主题中的模式。但是如果没有模式注册表,每条记录内部都有自己的模式,因此随时可以轻松更改模式。
那么当我使用架构注册服务器时如何更改架构。
您可以更改存储在 Confluent 模式注册表中的模式,只是默认配置强制向后兼容。您可以使用以下参数更改该兼容性配置:
avro.compatibility.level
Avro 兼容类型。有效值为:
none
(新模式可以是任何有效的 Avro 模式),
backward
(新模式可以读取最新注册模式产生的数据),
backward_transitive
(新模式可以读取之前注册的所有模式产生的数据),
forward
(最新注册的模式可以读取新模式产生的数据),
forward_transitive
(之前注册的所有模式都可以读取新模式产生的数据),
full
(新模式向后和向前兼容最新注册的模式),
full_transitive
(新模式向后和向前兼容所有以前注册的模式)
类型:字符串默认值:“向后”重要性:高
当我使用模式注册表服务器时,我发现我无法再更改同一主题中的模式。但是如果没有模式注册表,每条记录内部都有自己的模式,因此随时可以轻松更改模式。
那么当我使用架构注册服务器时如何更改架构。
您可以更改存储在 Confluent 模式注册表中的模式,只是默认配置强制向后兼容。您可以使用以下参数更改该兼容性配置:
avro.compatibility.level
Avro 兼容类型。有效值为:
none
(新模式可以是任何有效的 Avro 模式),backward
(新模式可以读取最新注册模式产生的数据),backward_transitive
(新模式可以读取之前注册的所有模式产生的数据),forward
(最新注册的模式可以读取新模式产生的数据),forward_transitive
(之前注册的所有模式都可以读取新模式产生的数据),full
(新模式向后和向前兼容最新注册的模式),full_transitive
(新模式向后和向前兼容所有以前注册的模式)
类型:字符串默认值:“向后”重要性:高