diff --git a/multi-binder-samples/multi-binder-kafka-streams/src/main/resources/application.yml b/multi-binder-samples/multi-binder-kafka-streams/src/main/resources/application.yml index 1860e7d..909c1c6 100644 --- a/multi-binder-samples/multi-binder-kafka-streams/src/main/resources/application.yml +++ b/multi-binder-samples/multi-binder-kafka-streams/src/main/resources/application.yml @@ -3,15 +3,6 @@ spring: stream: function: definition: sendTestData;process;receive;concatFn - kafka: - streams: - binder: - brokers: ${kafkaBroker2} - applicationId: multi-binder-kafka-streams - configuration: - default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde - default.value.serde: org.apache.kafka.common.serialization.Serdes$BytesSerde - commit.interval.ms: 1000 bindings: process-in-0: destination: dataIn @@ -24,8 +15,8 @@ spring: destination: dataIn binder: kafka1 concatFn-in-0: - destination: dataOut - binder: kafka3 + destination: dataOut + binder: kafka3 concatFn-out-0: destination: concatOut binder: kafka3 @@ -35,25 +26,38 @@ spring: binder: kafka2 binders: kafka1: - type: kafka - environment: - spring: - cloud: - stream: - kafka: - binder: - brokers: ${kafkaBroker1} + type: kafka + environment: + spring: + cloud: + stream: + kafka: + binder: + brokers: ${kafkaBroker1} kafka2: - type: kafka - environment: - spring: - cloud: - stream: - kafka: - binder: - brokers: ${kafkaBroker2} + type: kafka + environment: + spring: + cloud: + stream: + kafka: + binder: + brokers: ${kafkaBroker2} kafka3: - type: kstream + type: kstream + environment: + spring: + cloud: + stream: + kafka: + streams: + binder: + brokers: ${kafkaBroker2} + applicationId: multi-binder-kafka-streams + configuration: + default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde + default.value.serde: org.apache.kafka.common.serialization.Serdes$BytesSerde + commit.interval.ms: 1000 diff --git a/multi-binder-samples/multi-binder-kafka-streams/src/test/java/multibinder/TwoKafkaBindersApplicationTest.java b/multi-binder-samples/multi-binder-kafka-streams/src/test/java/multibinder/TwoKafkaBindersApplicationTest.java index 6b72eca..c419d6a 100644 --- a/multi-binder-samples/multi-binder-kafka-streams/src/test/java/multibinder/TwoKafkaBindersApplicationTest.java +++ b/multi-binder-samples/multi-binder-kafka-streams/src/test/java/multibinder/TwoKafkaBindersApplicationTest.java @@ -50,7 +50,6 @@ import static org.hamcrest.Matchers.equalTo; @SpringBootTest( webEnvironment = SpringBootTest.WebEnvironment.NONE) @DirtiesContext -@Ignore public class TwoKafkaBindersApplicationTest { @ClassRule