Spring Boot 自动配置加载 Spring Kafka 属性失败

Posted

技术标签:

【中文标题】Spring Boot 自动配置加载 Spring Kafka 属性失败【英文标题】:Spring Boot Auto Configuration Failed Loading Spring Kafka Properties 【发布时间】:2018-03-10 16:57:35 【问题描述】:

Spring boot 无法加载属性。这是我通过 yaml 文件使用的属性。

 spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      auto-commit-interval: 100
      enable-auto-commit: true
      group-id: ********************
      auto-offset-reset: earliest
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
    producer:
      batch-size: 16384
      buffer-memory: 33554432
      retries: 0
      value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
    listener:
      poll-timeout: 20000

我得到的例外是这个

原因:java.lang.IllegalAccessException:类 org.apache.kafka.common.utils.Utils 无法访问带有修饰符“protected”的类 org.springframework.kafka.support.serializer.JsonDeserializer 的成员

我认为构造函数是受保护的。请提供一种方法来实例化它。

【问题讨论】:

【参考方案1】:

没错。见:

protected JsonDeserializer() 
        this((Class<T>) null);
    

    protected JsonDeserializer(ObjectMapper objectMapper) 
        this(null, objectMapper);
    

    public JsonDeserializer(Class<T> targetType) 
        this(targetType, new ObjectMapper());
        this.objectMapper.configure(MapperFeature.DEFAULT_VIEW_INCLUSION, false);
        this.objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
    

JsonDeserializer 并非设计为由默认构造函数实例化,因为它需要知道 targetType 才能反序列化。

您可以将此类扩展到您的特定类型:

public class FooJsonDeserializer extends JsonDeserializer<Foo>  

并已将其用作该 value-deserializer 属性的类值。

或者你可以考虑自定义DefaultKafkaConsumerFactory

@Bean
public ConsumerFactory<?, ?> kafkaConsumerFactory(KafkaProperties properties) 
    Map<String, Object> consumerProperties = properties.buildConsumerProperties();
    consumerProperties.put(CommonClientConfigs.METRIC_REPORTER_CLASSES_CONFIG,
            MyConsumerMetricsReporter.class);
    DefaultKafkaConsumerFactory<Object, Object> consumerFactory =
          new DefaultKafkaConsumerFactory<>(consumerProperties);
    consumerFactory.setValueDeserializer(new JsonDeserializer<>(Foo.class));
    return consumerFactory;

【讨论】:

以上是关于Spring Boot 自动配置加载 Spring Kafka 属性失败的主要内容,如果未能解决你的问题,请参考以下文章

Spring Boot自动配置总结

如何在 Angular、spring-boot、maven 项目中配置项目以自动重新加载浏览器

Spring Boot

spring boot 自动配置原理

spring boot的spring.factories配置的不同类/以及加载时机

Spring Boot 2从入门到入坟 | 自动配置篇:源码分析之初始加载自动配置类