迁移至Quarkus 3后替代HeaderExtractAdapter获取Kafka Header方案咨询

Quarkus 3升级后，io.smallrye.reactive.messaging.kafka.tracing.HeaderExtractAdapter确实已被移除，你可以通过以下两种方式替代原有逻辑：

1. 使用SmallRye提供的KafkaHeaders工具类 #

SmallRye Reactive Messaging Kafka提供了io.smallrye.reactive.messaging.kafka.api.KafkaHeaders类，包含一系列便捷方法来读取Header：

• 获取字符串类型的首个Header值：

  import io.smallrye.reactive.messaging.kafka.api.KafkaHeaders;
  
  String value = KafkaHeaders.getFirstAsString(headers, headerName);
  

• 获取指定类型的首个Header值（比如字节数组、整数等）：

  byte[] bytesValue = KafkaHeaders.getFirst(headers, headerName, byte[].class);
  Integer intValue = KafkaHeaders.getFirst(headers, headerName, Integer.class);
  

2. 直接操作Kafka原生Headers对象 #

如果需要更灵活的处理（比如获取所有同名Header），可以直接使用Kafka原生的org.apache.kafka.common.header.Headers API：

• 获取首个Header值：

  import org.apache.kafka.common.header.Header;
  import org.apache.kafka.common.header.Headers;
  import java.nio.charset.StandardCharsets;
  
  Header header = headers.lastHeader(headerName); // 用headers.headers(headerName)可获取所有同名Header
  if (header != null) {
      String value = new String(header.value(), StandardCharsets.UTF_8);
      // 处理获取到的值
  }
  

• 遍历所有同名Header：

  for (Header header : headers.headers(headerName)) {
      String value = new String(header.value(), StandardCharsets.UTF_8);
      // 逐个处理每个Header值
  }
  

这两种方式都能完全替代原HeaderExtractAdapter.GETTER.get()的功能，其中KafkaHeaders工具类更贴近你之前的使用习惯，简化了类型转换和空值处理。

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