Spring Boot Kafka应用构建GraalVM原生镜像时找不到DefaultKafkaClientSupplier

基于Java Spring Boot的应用，使用spring-kafka和kafka-streams组件，通过命令mvn -Pnative spring-boot:build-image构建GraalVM原生镜像成功，但在Docker中运行该镜像时抛出以下异常：

Caused by: org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier for configuration default.client.supplier: Class org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier could not be found.
        at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:747)
        at org.apache.kafka.common.config.ConfigDef$ConfigKey.<init>(ConfigDef.java:1175)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:155)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:175)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:214)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:376)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:389)
        at org.apache.kafka.streams.StreamsConfig.<clinit>(StreamsConfig.java:1008)
        ... 16 common frames omitted

应用的Kafka配置如下：

spring:
  kafka:
    producer:
      value-serializer: "org.springframework.kafka.support.serializer.JsonSerializer"
      properties:
        spring:
          json:
            type:
              mapping: "ErrorReportDomain:com.kt.kafka.messagingprocessor.domain.ErrorReportDomain"
    client-id: messaging-processor
    bootstrap-servers:
      - "XXX"
    security:
      protocol: SASL_PLAINTEXT
    properties:
      sasl:
        mechanism: SCRAM-SHA-512
        jaas:
          config: org.apache.kafka.common.security.scram.ScramLoginModule required username="XXX" password="XXX";
    streams:
      application.id: messaging-processor
      properties:
        spring:
          json:
            trusted:
              packages: '*'
        default:
          key:
            serde: org.apache.kafka.common.serialization.Serdes$StringSerde
          value:
            serde: org.springframework.kafka.support.serializer.JsonSerde

解决建议 #

• 添加GraalVM反射配置
  GraalVM原生镜像编译时不会自动收录所有反射依赖类，DefaultKafkaClientSupplier是Kafka Streams内部通过反射加载的类，需手动配置。在src/main/resources/META-INF/native-image目录下创建reflect-config.json文件，写入以下内容：

  [
    {
      "name": "org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier",
      "allDeclaredConstructors": true,
      "allPublicConstructors": true,
      "allDeclaredMethods": true,
      "allPublicMethods": true,
      "allDeclaredFields": true,
      "allPublicFields": true
    }
  ]
  

• 验证版本兼容性
  确保spring-kafka、kafka-streams与Spring Boot版本完全兼容，旧版本Kafka组件的GraalVM原生支持可能存在缺陷，建议升级到官方推荐的稳定兼容版本（如Spring Boot 3.x搭配对应最新版Kafka组件）。

• 显式配置ClientSupplier
  在代码中手动指定Kafka Streams的客户端供应商，确保类被正确识别：

  @Bean
  public StreamsBuilderFactoryBeanCustomizer streamsBuilderFactoryBeanCustomizer() {
      return factoryBean -> {
          Map<String, Object> configs = new HashMap<>(factoryBean.getStreamsConfiguration());
          configs.put(StreamsConfig.DEFAULT_CLIENT_SUPPLIER_CLASS_CONFIG, DefaultKafkaClientSupplier.class);
          factoryBean.setStreamsConfiguration(configs);
      };
  }
  

• 利用Spring Native自动配置
  若使用Spring Boot 3.x，确保引入spring-boot-starter-native依赖，它会自动处理大部分Spring生态的原生镜像配置，再配合上述反射配置覆盖Kafka组件的特殊需求。

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