我可以通过编程方式设置属性spring.cloud.function.definition吗?



我为Kafka使用Spring Cloud流,并设置如下属性:

spring.cloud:
stream:
function.definition: method1;method2;...

我可以设置属性"spring.cloud.stream.function.definition"(或"spring.cloud.function.definition"哪个是相同的)在Java代码中?

我已经找到了解决方案:

StreamFunctionProperties streamFunctionProperties;
....
streamFunctionProperties.setDefinition("method1;method2");

最新更新