枚举值顺序不一致是否导致Kafka Schema Registry 40403错误？

问题详情 #

• 使用Spring Boot集成Kafka时，生产者无法发送消息，报错信息如下：

  Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema not found; error code: 40403
  

• 已确认Schema在Registry中存在，问题源于生产者与Kafka端Avro Schema的差异
• 此前生产者枚举缺少Kafka端的一个值，添加后仍报相同错误
• Kafka端枚举定义：

  enum Test { A, B, C }
  

• 生产者端枚举定义：

  enum Test { A, C, B }
  

回答 #

是，枚举值顺序不一致就是当前问题的诱因。

Avro对枚举类型的校验逻辑严格依赖定义顺序：它会将枚举值的索引（而非名称）作为序列化的核心标识，并且Schema Registry在对比Schema时，会把枚举值的顺序纳入全量校验范围。具体来说：

• Kafka端的枚举中，A对应索引0，B对应1，C对应2
• 生产者端的枚举中，A对应索引0，C对应1，B对应2

当生产者发送消息时，会按照自身的枚举索引序列化数据，但Schema Registry会将生产者提交的Schema与已注册的Schema进行严格比对——因为顺序不同，这会被判定为两个完全不同的Schema。如果生产者配置了使用已存在的Schema ID，或者Schema Registry启用了默认的兼容性规则（通常不允许这种顺序变更），就会触发"Schema not found"的40403错误。

解决方法 #

• 直接调整生产者端的枚举顺序，与Kafka端完全一致：enum Test { A, B, C }
• 若确实需要修改枚举顺序，可将Schema Registry的兼容性规则调整为forward或full（不推荐随意修改，可能影响下游消费者的序列化/反序列化逻辑）

内容的提问来源于stack exchange，提问作者f.trajkovski