From 162993dd46715d2c38e1fcda4f8f94a9ff5c9e95 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 22 Jun 2021 21:02:08 -0400 Subject: [PATCH] Test fixes for Kafka Streams jass config tests Provide different application id's. --- .../streams/bootstrap/KafkaStreamsBinderBootstrapTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java b/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java index ea977a4e7..cb3129146 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java +++ b/spring-cloud-stream-binder-kafka-streams/src/test/java/org/springframework/cloud/stream/binder/kafka/streams/bootstrap/KafkaStreamsBinderBootstrapTest.java @@ -96,11 +96,11 @@ public class KafkaStreamsBinderBootstrapTest { ConfigurableApplicationContext applicationContext = new SpringApplicationBuilder( SimpleKafkaStreamsApplication.class).web(WebApplicationType.NONE).run( "--spring.cloud.stream.kafka.streams.bindings.input-1.consumer.application-id" - + "=testKafkaStreamsBinderWithStandardConfigurationCanStart", + + "=testKafkaStreamsBinderWithStandardConfigurationCanStart-jaas", "--spring.cloud.stream.kafka.streams.bindings.input-2.consumer.application-id" - + "=testKafkaStreamsBinderWithStandardConfigurationCanStart-foo", + + "=testKafkaStreamsBinderWithStandardConfigurationCanStart-foo-jaas", "--spring.cloud.stream.kafka.streams.bindings.input-3.consumer.application-id" - + "=testKafkaStreamsBinderWithStandardConfigurationCanStart-foobar", + + "=testKafkaStreamsBinderWithStandardConfigurationCanStart-foobar-jaas", "--spring.cloud.stream.kafka.streams.binder.jaas.loginModule=org.apache.kafka.common.security.plain.PlainLoginModule", "--spring.cloud.stream.kafka.streams.binder.jaas.options.username=foo", "--spring.cloud.stream.kafka.streams.binder.jaas.options.password=bar",