当前位置: 首页 > 知识库问答 >
问题:

Spring云数据流服务器应用程序。属性被忽略

权承
2023-03-14

只是在试用春云流

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配合使用(据我所知应该是这样的)?如果您有任何建议,我们将不胜感激,谢谢。

共有1个答案

云俊名
2023-03-14

默认情况下,Spring Cloud Stream绑定属性由SCDF根据上述约定在内部设置。

应用程序。在应用程序级别定义的属性具有最低优先级,因此它们被SCDF设置的属性覆盖。

要覆盖SCDF设置的这些属性,需要通过streamdeploymentproperties传递新属性。您可以在此处查阅相关文档

如果您使用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是: 谁能帮我?