我使用 Spring Cloud Streams for Kafka 并设置如下属性:
spring.cloud:
stream:
function.definition: method1;method2;...
我可以在 Java 代码中设置属性
"spring.cloud.stream.function.definition"
(或 "spring.cloud.function.definition"
,这是相同的)吗?
我找到了解决方案:
StreamFunctionProperties streamFunctionProperties;
....
streamFunctionProperties.setDefinition("method1;method2");