Quarkus KafkaCompanion Avro消息序列化失败测试问题求助

以下是针对问题的具体排查方向：

• 确认Serde与KafkaCompanion的绑定逻辑
  测试代码中注册Avro Serde后，要确保消费时明确指定对应Serde，避免依赖未生效的全局配置。比如消费环节显式传入Serde实例：

  // 初始化并配置Serde（指定Schema Registry地址）
  AvroSerde<Coverage> coverageSerde = AvroSerde.of(Coverage.class);
  coverageSerde.configure(Map.of("schema.registry.url", "http://your-registry-url"), false); // false代表消费者端
  
  // 消费时关联Serde
  companion.consume(Topic.of("your-input-topic"), Consume.with(coverageSerde))
           .awaitCompletion(Duration.ofSeconds(10));
  

  检查是否存在Serde注册后未在Companion消费逻辑中关联的情况。

• 验证Schema Registry的测试环境状态

  • 确认测试用的Schema Registry服务已启动，且配置的schema.registry.url可访问；
  • 检查Coverage和GraphCoverage的Schema是否已注册到Registry：可以通过Registry的REST接口（比如GET /subjects/{topic-name}-value/versions）查询，或者确认测试代码中是否有自动注册Schema的逻辑（需开启auto.register.schemas=true配置）。

• 定位错误栈的根因
  从完整错误栈中找最底层的异常信息：

  • 若为RestClientException: Schema not found：说明Schema未注册，需手动注册或开启自动注册；
  • 若为AvroRuntimeException: Malformed data：可能是发送的消息格式不符合Avro规范，或Serde配置方向错误（比如把消费者Serde用在了生产者端）；
  • 若为MissingConfigurationException：检查Serde是否缺失schema.registry.url等核心配置。

• 检查扩展版本兼容性
  确保quarkus-confluent-registry-avro、smallrye-kafka、smallrye-kafka-companion的版本与Quarkus核心版本匹配，避免跨版本依赖冲突。比如Quarkus 3.x需使用对应3.x系列的扩展版本。

• 核对测试配置文件的有效性
  测试用application-test.properties中的Kafka通道配置仅对@Incoming/@Outgoing的消息流生效，KafkaCompanion的独立消费/生产逻辑不会自动继承这些配置。因此需手动给Companion的Serde或Producer/Consumer配置参数，不能依赖通道配置。

• 排查消息流的序列化方向
  错误提示“Error serializing Avro message”，注意区分是生产环节序列化还是消费环节反序列化抛出的异常：

  • 如果是测试代码中用Companion发送消息时出错，检查生产者端Serde的配置（configure方法第二个参数为true代表生产者）；
  • 如果是消费环节出错，可能是错误提示的表述混淆，实际是反序列化失败，需检查消费者Serde的Schema兼容性。

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