Kafka Schema Registry引用公共枚举Schema触发服务器内部错误

你将多个枚举打包在一个数组形式的Schema中，注册为commontypes-value主题。此时Schema Registry会将这个数组解析为Union类型（Avro规范中，数组形式的Schema会被识别为多类型联合），而非一组独立的命名Schema。当你尝试在Event Schema的引用中指定单个枚举名称时，Registry会尝试从Union类型中提取命名Schema，直接触发类型转换异常（UnionSchema无法转为NamedSchema）。

1. 拆分公共枚举为独立Schema文件 #

将每个枚举单独保存为一个Avro Schema文件：

• EventType.avsc

{
    "namespace": "org.example.test",
    "type": "enum",
    "name":"EventType",
    "symbols": ["CREATE","UPDATE","DELETE"]
}

• EventState.avsc

{
    "namespace": "org.example.test",
    "type": "enum",
    "name": "EventState",
    "symbols": ["OPEN","PROCESSED","CLOSED"]       
}

• SEVERITY.avsc

{
    "namespace": "org.example.test",
    "type": "enum",
    "name":"SEVERITY",
    "symbols": ["CRITICAL","HIGH","LOW"]
}

2. 单独注册每个枚举Schema到Registry #

将每个枚举文件分别注册到Schema Registry，使用对应的主题名称（比如eventtype-value、eventstate-value、severity-value），确保每个注册的Schema都是单一的命名枚举类型。

3. 修改Event Schema的引用配置 #

更新Event Schema的references参数，指向每个枚举对应的主题和版本：

"references": [
    {
       "name": "org.example.test.EventType",
       "subject":  "eventtype-value",
       "version": "1"
    },
    {
       "name": "org.example.test.EventState",
       "subject":  "eventstate-value",
       "version": "1"
    }
]

额外说明 #

• Avro的imports字段仅适用于本地文件系统的Schema引用，在Schema Registry环境中无需保留，可直接删除。
• 如果使用Confluent Schema Registry 7.0及以上版本，可借助Schema Groups功能将这些枚举Schema归为同一组便于管理，但核心仍需每个枚举作为独立Schema注册。

内容的提问来源于stack exchange，提问作者Lucia