应该使用 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(新模式向后和向前兼容所有以前注册的模式)

类型:字符串默认值:“向后”重要性:高