融合模式注册表：模式ID删除

Question

我们正在开发并尝试删除主题的模式，因为更改与旧模式不兼容。

我们删除了模式/主题，并尝试使用相同的主题名称创建新模式，成功创建了模式。

然而，当我们运行应用程序时，它仍然指向相同的模式ID。

旧模式ID（主题“topic1”）：51

新架构ID（主题“topic1”）：52

应用程序在反序列化消息时出错

    at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:736)
Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 51
Caused by: org.apache.avro.AvroTypeException: Found string, expecting union
    at org.apache.avro.io.ResolvingDecoder.doAction(ResolvingDecoder.java:292)
    at org.apache.avro.io.parsing.Parser.advance(Parser.java:88)
    at org.apache.avro.io.ResolvingDecoder.readIndex(ResolvingDecoder.java:267)
    at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumRea

<代码>root@bas：/#curl-khttps://schemaregistry:443/subjects/topic1/versions/latest

{"subject":"topic1","version":15,"id":52,"schema":"{\"type\":\"record\",\"name\":\"TopicOutputOutput\",\"namespace\":\"com.sagar.avsc\",\"fields\":[{\"name\":\"id\",\"type\":\"long\"},{\"name\":\"client\",\"type\":{\"type\":\"record\",\"name\":\"ClientObject\",\"fields\":[{\"name\":\"name\",\"type\":[\"null\",\"string\"]},{\"name\":\"client_id\",\"type\":[\"null\",\"long\"]},{\"name\":\"source_system_id\",\"type\":[\"null\",\"long\"]}]}},  ... 

更改：{“name\”：“client\u id\”，“type\”：[“null\”，“long\”]}

您可以看到模式ID为52，但应用程序正在尝试旧的模式ID（51），这与我们发送的数据不兼容

root@bas:/#  curl -k https://schemaregistry:443/schemas/ids/52
{"schema":"{\"type\":\"record\",\"name\":\"TopicOutputOutput\",\"namespace\":\"com.sagar.avsc\",\"fields\":[{\"name\":\"id\",\"type\":\"long\"},{\"name\":\"client\",\"type\":{\"type\":\"record\",\"name\":\"ClientObject\",\"fields\":[{\"name\":\"name\",\"type\":[\"null\",\"string\"]},{\"name\":\"client_id\",\"type\":[\"null\",\"long\"]},{\"name\":\"source_system_id\",

更改：{“name\”：“name\”，“type\”：[“null\”，“string\”]}

为什么应用程序仍然引用旧的模式ID？有没有办法删除模式ID？

Answer 1

您可以向/主题/：名称/版本/：版本

然而，模式ID 51仍然在主题中，在这些特定消息过期之前，或者在压缩主题的情况下被删除之前，无法从主题中删除它。

如果模式不兼容，那么我会检查注册表的配置，因为默认情况下，它不允许向后不兼容的更改。