Не удается пометить DEFAULT_STREAMS_CONFIG_BEAN_NAME в качестве основного

Question

Я только что обновился до весенней загрузки 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]

Я ожидал бы преодолеть эту проблему, пометив один из двух StreamsBuilderFactoryBean (s) как @Primary (как предлагается здесь ). Но даже если я и сделаю:

@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 делает построенные бины первичными. Любая помощь более чем ценится!

РЕДАКТИРОВАТЬ : я обошел проблему, удалив @EnableKafkaStreams и DEFAULT_STREAMS_BUILDER_BEAN_NAME. В результате KafkaStreamsFactoryBeanConfigurer не срабатывает.

Answer 1

В моем случае я обошел проблему, удалив @EnableKafkaStreams (т. Е. Потоковые компоненты не создаются автоматически), и вручную создаю все необходимые компоненты. Выглядит еще лучше, если у вас есть более одного потока, так как наименование может быть более деструктивным.

Answer 2

Я не уверен, почему @Primary не работал. Я открыл GitHub выпуск .