我为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");