在Spring Cloud Data Flow中部署现有的Spring Cloud Stream

Question

spring:
  application:
    name: myapp

  cloud:
    stream:
      bindings:
        output:
          destination: topic1
          producer:
            partitionCount: 5
            partitionKeyExpression: headers.kafka_messageKey
      kafka:
        binder:
          brokers: 10.138.128.62
          defaultBrokerPort: 9092
          zkNodes: 10.138.128.62
          defaultZkPort: 2181
          requiredAcks: -1
          replicationFactor: 1
          autoCreateTopics: true
          autoAddPartitions: true
        bindings:
          output:
            producer:
              configuration:
                key.serializer: org.apache.kafka.common.serialization.StringSerializer
                value.serializer: org.apache.kafka.common.serialization.ByteArraySerializer

java -jar mycomponent.jar --spring.config.location=/conf/application.yml

目前，我“手动”编排这3个组件，但我希望使用Spring Cloud Data Flow(SCDF)来创建流，并能够更好地操作它们。

根据SCDF文档，任何SCS应用程序都可以直接用作要在流中定义的应用程序。除此之外，应用程序的属性可以通过外部属性文件提供。但是，我提供了我的'application.yml'属性文件，但它不起作用：

stream deploy --name mystream --definition "mysource | myprocessor | mysink' --deploy --propertiesFile /conf/application.yml

经过一些研究，我意识到文档声明任何应用程序的任何属性都必须以这种格式传递：

app.<app-name>.<property-name>=<value>

null

Answer 1

我必须添加那个“应用程序”吗我现有的所有财产？

是的。你可以有这样的东西：

app:app-name:spring:cloud:...

您是否出于某种原因在应用程序中显式地使用spring.application.name。我想如果更改spring.application.name，将会对metrics collector产生一些影响。

如果我已经在application.yml中提供了“server.port”属性，它对SCDF有何影响？SCDF会选择它作为应用程序使用的端口还是忽略它？

它的工作方式与Spring Boot属性源优先级相同。应用程序的application.yml中的server.port将获得比其他可以通过流定义/部署属性设置的属性源最小的优先级。