Überschreiben von Eigenschaften in der Spring Cloud Dataflow-Stream-Definition

Question

Für Kafka-Streams (Consumers), die KafkaAvroDeserializer verwenden, muss ich einige Konfigurationen bei der Bereitstellung mit --propertiesFile überschreiben, um zu funktionieren. KafkaBinder 1.1.1 hat diese Konfigurationsoption hinzugefügt.

Ich bevorzuge es, Bereitstellungseigenschaften zu verwenden, wenn ich kann, weil sie nicht auf dem Dashboard sichtbar sind und es gefährlich ist, wenn ein anderer Benutzer einen Stream stoppt und neu startet, ohne die Eigenschaften festzulegen. Ist es möglich, diese Eigenschaften in die Stream-Definition aufzunehmen? Meine wiederholten Versuche haben versagt zu arbeiten. Ich sehe kein Beispiel dafür auf dem Referenzdokument.

z.B. für yaml äquivalent:

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

Answer 1

Sie können diese Frühlings-Cloud-Stream-Eigenschaften in Data Flow Stream-Definition DSL wie folgt angeben:

Strom a1 --definition „Zeit --spring.cloud.stream erstellen. kafka.binder.configuration.value.serializer = Serialisierung | log --spring.cloud.stream.kafka.binder.configuration.value.deserializer = Deserializer --spring.cloud.stream.kafka.binder.configuration.schema.registry. url = 'http://myregistry' "--deploy