解边界可能会产生无效的模式

Question

我面临Avro和模式注册表的问题。在Debezium创建了一个模式和一个主题之后，我从模式注册表下载了该模式。我把它放在一个.asvc文件中，它看起来像这样：

  {
    "type": "record",
    "name": "Envelope",
    "namespace": "my.namespace",
    "fields": [
      {
        "name": "before",
        "type": [
          "null",
          {
            "type": "record",
            "name": "MyValue",
            "fields": [
              {
                "name": "id",
                "type": "int"
              }
            ]
          }
        ],
        "default": null
      },
      {
        "name": "after",
        "type": [
          "null",
          "MyValue"
        ],
        "default": null
      }
    ]
  }

我做了两个实验：

>

我使用avro maven插件中的“生成源代码”来生成Java类。当我尝试使用上述主题时，我看到了以下错误：

线程“b2-StreamThread-1”中的异常org.apache.kafka.streams.errors.StreamsException：进程中捕获的异常。[...]：注册Avro模式时出错：[...]

原因：io.confluent.kafka.schemaregistry.client.rest.exceptions。RestClientException：正在注册的模式与早期的模式不兼容；错误代码：409

有没有人面临同样的问题？是Debezium产生了无效的模式，还是模式注册表有缺陷？

Answer 1

MyValue不正确。

这不是Avro类型。您必须将实际记录嵌入到联合中，就像before值一样

换句话说，您无法交叉引用模式中的记录类型，AFAIK

当我尝试使用上述主题时，我看到了以下错误：

消费者不注册模式，所以不清楚你是如何得到这个错误的，除非可能使用Kafka流，它生成中间主题