根据Spring Cloud Data Flow(SCDF)的文档,只有前缀为“deployded”的属性。或者“应用程序”。在部署应用程序(无论是源、处理器还是接收器)时,都考虑作为流的一部分。
propertiesToUse = DeploymentPropertiesUtils.convert(props);
public static Map<String, String> convert(Properties properties) {
Map<String, String> result = new HashMap<>(properties.size());
for (String key : properties.stringPropertyNames()) {
result.put(key, properties.getProperty(key));
}
return result;
}
我认为这种行为是故意的,但为什么呢?为什么不直接用适当的前缀提取用户定义的所有属性呢?
谢谢你的支持。
所有部署属性都应该是map
的,基于部署者SPI设置的约定。
我相信其中一个原因是字符串键,值被传递到目标部署平台没有序列化/反序列化的障碍。并且,使用字符串值类似于在目标部署平台中将这些键值属性设置为环境变量(例如)。
只是在试用春云流 当我把它作为一个独立的jar运行时(就像另一个springboot应用程序一样),它尊重这个应用程序。物业和所有工程按预期进行。 当我使用SCDF创建流时,它会忽略属性,并使用约定流名称创建交换。app_名称不是我想要的。 我希望在某个时候,我希望这些应用程序与SpringCloudConfig服务器集成,在那里我可以从不同的来源完全外部化配置。 有人可以建议我遗漏了什么,以便S
我正在从Spring XD迁移到Spring Cloud Data Flow。当我寻找模块列表时,我意识到一些源码没有在Spring Cloud Flow中列出--其中一个是Kafka源码。 我的问题是为什么在spring cloud data flow中KAFKA源从标准源列表中删除?
顺便说一句:我的应用程序是一些REST控制器和一些批处理作业的组合。那么使用云数据流有意义吗?如果没有,那么是否有更好的控制台管理器用于批处理作业(如重新启动、取消作业门户)等?
我有一个现有的过程,我正试图转换成SCDF实现。目前的流程是, HTTP接收器(接收HTTP POST数据)->RabbitMQ->MQ接收器服务->处理/转换->DB接收器
我有一个从流-任务-启动器-数据流调用的组合任务 我将流处理器中的几个属性传递给任务启动器数据流和子任务,例如。。。 这可以正常工作,但我已经达到了最大字符限制,并在组合任务pod上得到一个sql异常,说明我已经超过了2500个字符的限制。我想为所有任务而不是单独设置属性以节省字符空间,但使用通配符不起作用 有没有办法为所有任务设置属性,而不必单独设置? 我尝试在kubernetes中的Sprin