Kafka的Spring Boot-一个应用程序中的多个KafkaStreams配置

问题描述

在春季，kafka流可以在一个应用程序中定义两个配置吗？ 如果我们有两个@Bean这样的配置，如何在流中使用secondConfig？

@Configuration
@EnableKafkaStreams
public class KafkaStreamConfig {

    @Bean(name = KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME)
    public KafkaStreamsConfiguration kafkaStreamConfig() {
        var props = new HashMap<String,Object>();

        props.put(StreamsConfig.APPLICATION_ID_CONFIG,"kafka-stream");
        props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");

        ....
 
        return new KafkaStreamsConfiguration(props);
    }

    @Bean(name = "secondConfig")
    public KafkaStreamsConfiguration kafkaStreamConfig() {
        var props = new HashMap<String,"other-machine:9092");

        ....
 
        return new KafkaStreamsConfiguration(props);
    }


}

谢谢

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）