diff --git a/rxjava-processor/src/main/resources/application.yml b/rxjava-processor/src/main/resources/application.yml index 8668638..9b51624 100644 --- a/rxjava-processor/src/main/resources/application.yml +++ b/rxjava-processor/src/main/resources/application.yml @@ -4,5 +4,7 @@ spring: cloud: stream: bindings: - output: xformed - input: testtock + output: + destination: xformed + input: + destination: testtock diff --git a/sink/src/main/resources/application.yml b/sink/src/main/resources/application.yml index d469a0f..682bd5a 100644 --- a/sink/src/main/resources/application.yml +++ b/sink/src/main/resources/application.yml @@ -4,9 +4,10 @@ spring: cloud: stream: bindings: - input: testtock - # uncomment below to have this module consume from a specific partition - # in the range of 0 to N-1, where N is the upstream module's partitionCount - #consumerProperties: - # partitionIndex: 1 + input: + destination: testtock + # uncomment below to have this module consume from a specific partition + # in the range of 0 to N-1, where N is the upstream module's partitionCount + #consumerProperties: + # partitionIndex: 1 \ No newline at end of file diff --git a/source/src/main/resources/application.yml b/source/src/main/resources/application.yml index 72f476d..9cea1b4 100644 --- a/source/src/main/resources/application.yml +++ b/source/src/main/resources/application.yml @@ -21,4 +21,5 @@ spring: cloud: stream: bindings: - output: xformed + output: + destination: xformed diff --git a/transform/src/main/resources/application.yml b/transform/src/main/resources/application.yml index f62709e..9b51624 100644 --- a/transform/src/main/resources/application.yml +++ b/transform/src/main/resources/application.yml @@ -4,6 +4,7 @@ spring: cloud: stream: bindings: - output: xformed - input: testtock - \ No newline at end of file + output: + destination: xformed + input: + destination: testtock