在使用 Avro 进行 Kafka 消息序列化/反序列化时，若 Schema 中定义了 decimal 逻辑类型（如 union { decimal(10,2), null }），Java 端对应 BigDecimal，但默认 DatumReader 无法识别该类型，导致 AvroRuntimeException: Unknown datum type java.math.BigDecimal。需显式注册 DecimalConversion 逻辑类型转换器。
在使用 avro 进行 kafka 消息序列化/反序列化时，若 schema 中定义了 `decimal` 逻辑类型（如 `union { decimal(10,2), null }`），java 端对应 `bigdecimal`，但默认 `datumreader` 无法识别该类型，导致 `avroruntimeexception: unknown datum type java.math.bigdecimal`。需显式注册 `decimalconversion` 逻辑类型转换器。
Avro 原生不直接支持 java.math.BigDecimal，而是通过 逻辑类型（Logical Types）（如 decimal）在 Schema 层声明语义，并依赖 Conversion 机制在运行时桥接 Java 类型与二进制编码。当使用 SpecificDatumReader（或 GenericDatumReader）读取包含 decimal 字段的 Avro 二进制数据时，若未预先注册对应的逻辑类型转换器，Avro 将无法将底层的 bytes 或 fixed 解码为 BigDecimal，从而抛出 AvroRuntimeException: Unknown datum type java.math.BigDecimal。
✅ 正确解决方案是在执行反序列化前，向全局 GenericData 实例注册 Conversions.DecimalConversion：
// 必须在 read() 调用前执行一次（通常放在测试 setup 或静态初始化块中） GenericData.get().addLogicalTypeConversion(new Conversions.DecimalConversion());
完整单元测试代码示例如下：
@BeforeEach
void setUp() {
// 注册 BigDecimal 转换器（关键！）
GenericData.get().addLogicalTypeConversion(new Conversions.DecimalConversion());
this.eventReader = new SpecificDatumReader<>(Event.class);
}
@Test
void testEventWithDecimalCost() {
// 发送含 cost: 8.32 的事件（已按 Avro schema 序列化）
// ... 生产者逻辑 ...
// 消费并反序列化
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)
);
// 断言
assertThat(event.getCost()).isEqualTo(new BigDecimal("8.32"));
}⚠️ 注意事项：
- 该注册只需执行一次（推荐在测试类初始化阶段），无需每次
read()前重复调用； - 若项目中混合使用
GenericRecord和SpecificRecord，同样适用此方案； - 确保 Avro 版本 ≥ 1.8.2（
Conversions.DecimalConversion自此版本起稳定支持）； - 若使用 Confluent Schema Registry + Kafka Avro Serializer，生产端已自动处理
decimal编码，但消费端DatumReader仍需手动注册转换器； - 避免在多线程并发读取场景中修改
GenericData.get()—— 它是线程安全的，但注册操作本身应确保只发生一次。
总结：Avro 对 decimal 等逻辑类型的 Java 绑定并非开箱即用，必须显式启用类型转换。添加 GenericData.get().addLogicalTypeConversion(new Conversions.DecimalConversion()) 是解决 Unknown datum type java.math.BigDecimal 错误的标准且可靠方式。
