如何解决AvroTypeException: Unknown union branch报错

抛出org.apache.avro.AvroTypeException: Unknown union branch id的核心原因是Avro union类型的分支指定层级搞错了：

• 你提供的Schema里，只有before字段是union类型，可选分支为null、命名空间为datachanges.article的Value类型记录
• id字段本身是基础int类型，不属于union，不需要额外包裹分支结构
• 第一组测试数据没有给before这个union字段指定非null值对应的分支类型名，序列化器解析到before的值是对象时，会把对象的第一个key（也就是id）错当成union分支名去匹配，自然找不到对应分支；第二组测试数据错误地给非union的id字段套了union分支写法，进一步触发类型不匹配。

Avro对union类型的JSON序列化规则是：非null值必须用对应分支的完整类型名作为key，包裹实际的记录内容。针对你当前的Schema，正确的消息结构如下：

{
  "before": {
    "datachanges.article.Value": {
      "id": 345530
    }
  }
}

如果需要传before为null的场景，直接写{"before": null}即可，不需要额外包裹结构。

执行kafka-avro-console-producer时，建议补充以下参数避免异常：

• 显式指定--property value.schema.id=<Schema Registry中该Schema对应的ID>，不要依赖工具自动推导Schema，避免和Debezium已注册的Schema产生兼容性冲突
• 关闭自动注册Schema参数：--property auto.register.schemas=false，防止工具把传入的消息结构识别为新Schema注册，覆盖Debezium维护的原有Schema
• 如需自动匹配已注册的最新版本Schema，可添加--property use.latest.version=true，不要混用其他Schema自动匹配参数。

内容的提问来源于stack exchange，提问作者Ciro di Marzo