From 70eb25d413813ea52a1054ceb30a2351e72c1f15 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 9 Apr 2019 13:02:57 -0400 Subject: [PATCH] Fix failing test --- .../streams/integration/MultiProcessorsWithSameNameTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameTests.java b/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameTests.java index 51ab319d6..4c23eacaa 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameTests.java +++ b/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/integration/MultiProcessorsWithSameNameTests.java @@ -57,7 +57,7 @@ public class MultiProcessorsWithSameNameTests { "--spring.cloud.stream.bindings.input-2.destination=words", "--spring.cloud.stream.bindings.output.destination=counts", "--spring.cloud.stream.bindings.output.contentType=application/json", - "--spring.cloud.stream.kafka.streams.bindings.input.consumer.application-id=basic-word-count", + "--spring.cloud.stream.kafka.streams.bindings.input-1.consumer.application-id=basic-word-count", "--spring.cloud.stream.kafka.streams.bindings.input-2.consumer.application-id=basic-word-count-1", "--spring.cloud.stream.kafka.streams.binder.brokers=" + embeddedKafka.getBrokersAsString(),