只是在试用春云流
spring.cloud.stream.bindings.input.destination=work.in
spring.cloud.stream.bindings.input.contentType=text/plain
spring.cloud.stream.bindings.input.binder=rabbit
spring.cloud.stream.bindings.input.group=testgroup
spring.cloud.stream.bindings.output.destination=work.out
spring.cloud.stream.bindings.output.contentType=text/plain
spring.cloud.stream.bindings.output.binder=rabbit
spring.cloud.stream.bindings.output.group=testgroup
当我把它作为一个独立的jar运行时(就像另一个springboot应用程序一样),它尊重这个应用程序。物业和所有工程按预期进行。
当我使用SCDF创建流时,它会忽略属性,并使用约定流名称创建交换。app_名称不是我想要的。
我希望在某个时候,我希望这些应用程序与SpringCloudConfig服务器集成,在那里我可以从不同的来源完全外部化配置。
有人可以建议我遗漏了什么,以便SCDF接受我的申请。属性以及SCDF是否与SpringCloudConfigServer配合使用(据我所知应该是这样的)?如果您有任何建议,我们将不胜感激,谢谢。
默认情况下,Spring Cloud Stream绑定属性由SCDF根据上述约定在内部设置。
应用程序。在应用程序级别定义的属性具有最低优先级,因此它们被SCDF设置的属性覆盖。
要覆盖SCDF设置的这些属性,需要通过stream
deployment
properties传递新属性。您可以在此处查阅相关文档
如果您使用Spring Cloud Config server来提供外部化属性,我相信这些属性只能用作流
定义
属性,而不能用于部署
属性,就像我们用来覆盖Spring Cloud流绑定属性的属性一样。
在spring cloud dataflow中,根据我的理解,每个流都是一个微服务,但数据流服务器不是。我说的对吗?
根据Spring Cloud Data Flow(SCDF)的文档,只有前缀为“deployded”的属性。或者“应用程序”。在部署应用程序(无论是源、处理器还是接收器)时,都考虑作为流的一部分。 我认为这种行为是故意的,但为什么呢?为什么不直接用适当的前缀提取用户定义的所有属性呢? 谢谢你的支持。
我正在自学SpringCloudConfig服务器,在将属性注入bean时遇到了一些问题。 因此,我有一个简单的Spring Boot应用程序作为配置客户端,仅用于测试: 但系统会打印: 检查envendpoint时,我实际上发现属性位于环境中: 请注意,在中,有一个名为的属性,其值为 我是Spring框架的新手,所以我想知道我是不是搞砸了什么?有人建议我也可以使用访问外部属性,但我没有找到太多关
我正在使用docker部署spring云数据流服务器。我在dataflow服务器内部创建了一个数据处理管道,通过部署两个spring boot应用程序作为源、处理器和接收器。为了访问每个服务的日志,我必须从docker continer(bash)内部跟踪它,或者将其从docker容器复制到本地磁盘。 我想使用log4j-kafka appender将这些日志推送给kafka以供以后分析。我已经为
我想使用keycloak作为身份验证和授权服务器来保护spring cloud数据流服务器并管理对其endpoint的访问。 我按照Spring的文档http://docs.spring.io/spring-cloud-dataflow/docs/1.7.0.rc1/reference/htmlsingle/#configuration-security-oauth2中的描述设置了scdf服务器的
我正在研究和使用Spring Cloud数据流进行一些概念验证,但遇到了一些问题: 我正在尝试启动本地数据流服务器。为了实现这一点,我创建了一个Spring Boot应用程序,并用< code > @ EnableDataFlowServer 对其进行了注释。 当我尝试运行时,我收到以下错误: 我在寻求帮助,我读到这可能是一个pom的版本问题。实际上我的< code>pom.xml是: 谁能帮我?