Spring cloud stream kafka binder创建按需配置的消费者

Question

我用的是Spring boot 1.5.9.RELEASE和Spring cloud Edgware。跨微服务发布。

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

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

有什么直接的方法吗？

Answer 1

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

@SpringBootApplication
public class SpringDataDemoApplication {

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