覆盖 Spring Cloud Dataflow 流定义中的属性

Question

对于使用 KafkaAvroDeserializer 的 Kafka 流（消费者），我需要使用 --propertiesFile 在部署时覆盖一些配置才能工作。 KafkaBinder 1.1.1 添加了这个配置选项。

如果可以的话，我宁愿不使用部署属性，因为它们在仪表板上不可见，如果另一个用户决定停止并重新启动流而不设置属性，那将是危险的。是否可以在流定义中包含这些属性？我的反复尝试都没有奏效。我在参考文档中没有看到这方面的示例。

例如对于 yaml 等价物：

<...>
binder:
  configuration:
    value.deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
    schema.registry.url: http://my.dns.com:8081

Answer 1

您可以在 Data Flow Stream 定义 DSL 中指定这些 Spring Cloud Stream 属性，如下所示：

stream create a1 --definition "time --spring.cloud.stream.kafka.binder.configuration.value.serializer=serializer | log --spring.cloud.stream.kafka.binder.configuration.value.deserializer=deserializer --spring.cloud.stream.kafka.binder.configuration.schema.registry.url='http://myregistry'" --deploy

覆盖 Spring Cloud Dataflow 流定义中的属性

Overriding properties in Spring Cloud Dataflow stream definition

spring-cloud-dataflow