From fabae1c6f486f122b07c4b4e4f68a943f45bb503 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Thu, 17 Mar 2016 09:50:44 -0400 Subject: [PATCH] added explicit destination properties --- rxjava-processor/src/main/resources/application.yml | 6 ++++-- sink/src/main/resources/application.yml | 11 ++++++----- source/src/main/resources/application.yml | 3 ++- transform/src/main/resources/application.yml | 7 ++++--- 4 files changed, 16 insertions(+), 11 deletions(-) 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