Переопределение свойств в определении потока Spring Cloud Dataflow

Question

Для потоков Kafka (потребителей), которые используют KafkaAvroDeserializer, мне нужно переопределить некоторые настройки при развертывании с помощью --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

Вы можете указать эти свойства Spring Cloud Stream в DSL определения потока данных следующим образом:

поток создать a1 - определение "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