覆盖 KafkaAutoConfiguration 时出错

Question

我正在尝试覆盖 KafkaAutoConfiguration，因为我已将生产者和消费者配置分离到不同的属性文件中。

@Configuration(proxyBeanMethods=false)
@ConditionalOnClass(value=org.springframework.kafka.core.KafkaTemplate.class)
@PropertySources({
    @PropertySource("classpath:producer-config2.properties"),
    @PropertySource("classpath:consumer-config.properties")
})
@EnableConfigurationProperties(value=KafkaProperties.class)
@Import(value={org.springframework.boot.autoconfigure.kafka.KafkaAnnotationDrivenConfiguration.class,org.springframework.boot.autoconfigure.kafka.KafkaStreamsAnnotationDrivenConfiguration.class})
public class KafkaAutoConfiguration {

}

问题来自第 8 行 @Import(value={org.springframework.boot.autoconfigure.kafka.KafkaAnnotationDrivenConfiguration.class,org.springframework.boot.autoconfigure.kafka.KafkaStreamsAnnotationDrivenConfiguration.class})
，我在其中收到错误：
The type org.springframework.boot.autoconfigure.kafka.KafkaAnnotationDrivenConfiguration is not visible、
The type org.springframework.boot.autoconfigure.kafka.KafkaStreamsAnnotationDrivenConfiguration is not visible

但是当我在我的 IDE 中 F3 进入这个 class 时，我能够很好地看到两个 classes。这有什么问题？我该如何解决这个问题？

Answer 1

class KafkaAnnotationDrivenConfiguration {

class 是包私有的，因此仅对同一包中的其他 class 可见；你不能从你的 class.

引用它

您可以在 IDE 中导航到它这一事实无关紧要。

覆盖 KafkaAutoConfiguration 时出错

Error with overriding KafkaAutoConfiguration

spring

spring-boot

spring-kafka