为spring云流aws kinesis binder配置动态流输入目的地名称

wnavrhmk  于 2021-07-24  发布在  Java
关注(0)|答案(1)|浏览(364)

有没有办法通过bean而不是属性spring.cloud.stream.bindings.input.destination=property来配置使用者流名称?
我们有一个用例,在这个用例中,我们希望使用易受更改影响的流名称,而不能硬编码它。
我们在运行时没有可用的流名称,但在引导上下文初始化过程中作为属性源属性加载并可用。

5rgfhyps

5rgfhyps1#

你可以在那里使用占位符

spring.cloud.stream.bindings.input.destination=${destination.name:defaultDest}

然后你可以把它作为 -Ddestination.name=foo .

相关问题