在使用 Avro 进行 Kafka 消息单元测试时，若 Schema 中定义了 decimal 逻辑类型（如 union { decimal(10,2), null }），Java 端对应 BigDecimal 字段，直接使用 SpecificDatumReader 反序列化会因缺失逻辑类型转换器而抛出 AvroRuntimeException: Unknown datum type java.math.BigDecimal。需显式注册 DecimalConversion 转换器。
在使用 avro 进行 kafka 消息单元测试时，若 schema 中定义了 `decimal` 逻辑类型（如 `union { decimal(10,2), null }`），java 端对应 `bigdecimal` 字段，直接使用 `specificdatumreader` 反序列化会因缺失逻辑类型转换器而抛出 `avroruntimeexception: unknown datum type java.math.bigdecimal`。需显式注册 `decimalconversion` 转换器。
Avro 原生不直接支持 java.math.BigDecimal，而是通过逻辑类型（Logical Types）（如 decimal）在 Schema 层抽象精度与标度，并依赖 Conversion 机制在运行时桥接 Avro 内部二进制表示（ByteBuffer）与 Java 类型。SpecificDatumReader 默认仅支持基础类型（如 String、Integer、Double），对 decimal 这类逻辑类型需手动注入对应的 Conversion 实现。
✅ 正确做法是在反序列化前，向全局 GenericData 实例注册 Conversions.DecimalConversion()：
// 必须在 read() 调用前执行一次（通常放在 @Before 或静态初始化块中）
GenericData.get().addLogicalTypeConversion(new Conversions.DecimalConversion());
// 后续读取逻辑保持不变
final ConsumerRecord<string byte> eventMessage = KafkaTestUtils.getSingleRecord(
kafkaConsumer, eventTopic, Duration.ofSeconds(10).toMillis()
);
final Event event = eventReader.read(
null,
DecoderFactory.get().binaryDecoder(eventMessage.value(), null)
);</string>
⚠️ 注意事项：
-
仅需注册一次：
GenericData.get()是单例，addLogicalTypeConversion是全局生效的，无需每次读取消息都重复调用； -
顺序关键：必须在
eventReader.read(...)之前完成注册，否则反序列化仍会失败； -
兼容性保障：
Conversions.DecimalConversion自 Avro 1.8.0 起内置，确保项目依赖 Avro ≥ 1.8.0（推荐使用 1.11.x 或更高稳定版）； -
非 SpecificReader 场景：若使用
GenericDatumReader或ReflectDatumReader，同样需注册该转换器，逻辑一致； -
Schema 验证：确认
.avsc文件中字段确实声明为{"type": ["null", {"type": "bytes", "logicalType": "decimal", "precision": 10, "scale": 2}]}—— Avro Maven 插件生成的 Java 类会据此映射为BigDecimal。
? 补充建议：在测试类初始化阶段统一配置，提升可维护性：
@BeforeAll
static void setupAvroConversions() {
GenericData.get().addLogicalTypeConversion(new Conversions.DecimalConversion());
}
至此，BigDecimal 字段即可被正确解析，单元测试可稳定验证 Kafka 事件中高精度数值字段的端到端正确性。
