无法将DEFAULT_STREAMS_CONFIG_BEAN_NAME标记为主要

Question

我刚刚升级到spring-boot 2.1.3.release，由于这个新的类/方法，我不能拥有多个StreamsBuilderFactoryBean(KafKastreamsFactoryBeanConfigurer只需要一个FactoryBean):

@Configuration
@ConditionalOnClass(StreamsBuilder.class)
@ConditionalOnBean(name = 
KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_BUILDER_BEAN_NAME)
class KafkaStreamsAnnotationDrivenConfiguration {
 //...
 @Bean
 public KafkaStreamsFactoryBeanConfigurer kafkaStreamsFactoryBeanConfigurer(
        StreamsBuilderFactoryBean factoryBean) {
    return new KafkaStreamsFactoryBeanConfigurer(this.properties, factoryBean);
 }
}

我得到这个错误：

Parameter 0 of method kafkaStreamsFactoryBeanConfigurer in org.springframework.boot.autoconfigure.kafka.KafkaStreamsAnnotationDrivenConfiguration required a single bean, but 2 were found:
- &defaultKafkaStreamsBuilder: defined by method 'defaultKafkaStreamsBuilder' in class path resource [com/elsevier/q2c/transaction/snapshot/builder/config/KafkaStreamsConfig.class]
- &snapshotKafkaStreamsBuilder: defined by method 'snapshotKafkaStreamsBuilder' in class path resource [com/elsevier/q2c/transaction/snapshot/builder/config/KafkaStreamsConfig.class]

@Bean(name = KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_BUILDER_BEAN_NAME)
@Primary
public StreamsBuilderFactoryBean defaultKafkaStreamsBuilder(
        @Qualifier(KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME) KafkaStreamsConfiguration streamsConfiguration) {
    StreamsBuilderFactoryBean streamsBuilderFactoryBean = new StreamsBuilderFactoryBean(streamsConfiguration);
    return streamsBuilderFactoryBean;
}

@Bean(name = SNAPSHOT_STREAMS_BUILDER_BEAN_NAME)
public StreamsBuilderFactoryBean snapshotKafkaStreamsBuilder(
        @Qualifier(SNAPSHOT_STREAMS_CONFIG_BEAN_NAME) KafkaStreamsConfiguration streamsConfiguration) {
    StreamsBuilderFactoryBean streamsBuilderFactoryBean = new StreamsBuilderFactoryBean(streamsConfiguration);
    return streamsBuilderFactoryBean;
}

我在想，也许@primary使构造的bean成为一个主要的bean。任何帮助都超过感激！

编辑：我通过删除@enablekafkastreams和default_streams_builder_bean_name来规避这个问题。因此，KafKastreamsFactoryBeanConfigurer不起作用。

Answer 1

在我的例子中，我通过删除@enablekafkastreams（即没有自动创建流beans)，并手动创建所有需要的流beans来绕过这个问题。如果您有多个流，看起来会更好，因为命名也会更容易删除。