Spring Cloud Stream kafka binder 以按需配置创建消费者答案

【问题标题】：Spring cloud stream kafka binder to create consumer with on demand configurationSpring Cloud Stream kafka binder 以按需配置创建消费者
【发布时间】：2018-06-20 11:42:14
【问题描述】：

我在微服务中使用 Spring boot 1.5.9.RELEASE 和 Spring cloud Edgware.RELEASE。

我已经使用@EnableBinding 注释绑定了一个消费者。注释将为我完成其余部分以使用事件。

提出了一些手动配置主题名称和一些其他配置属性的要求，我想在应用程序启动时覆盖在 application.properties 中定义的消费者的一些属性。

有没有直接的方法？

【问题讨论】：

你能澄清一下吗？您是否尝试重新配置已使用属性机制配置的内容？
我有一个微服务 M1，在 M1 启动时，我从另一个微服务 M2 获取 Kafka 主题名称。此后我需要使用这个主题来消费事件。
有一个open issue to add programmatic binding。

标签： spring-boot spring-cloud spring-cloud-stream

【解决方案1】：

您可以使用初始化 bean，它可以完成工作：

@SpringBootApplication
public class SpringDataDemoApplication {

    @Bean
    InitializingBean populateDatabase() {
        return () -> {
            // doWhatYouWantHere...
        };
}

【讨论】：

我需要通过进行外部调用来进行配置并提供相同的配置来启动 Kafka 消费者，在初始化 bean 时是不可能的，因为进行外部调用的依赖关系可能正在进行中上来。无论如何，我已经解决了这个问题。