home/spring-cloud-stream-samples
2
0
Fork 0
mirror of https://github.com/wahyd4/spring-cloud-stream-samples.git synced 2026-08-09 05:16:18 +10:00
Code Issues Packages Projects Releases Wiki Activity

Fixing issues with multi binder Kafka Streams sample

Browse Source
This commit is contained in:
Soby Chacko
2020-03-06 18:40:16 -05:00
parent 5c29947a5e
commit dec7c4c5a7
2 changed files with 32 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
multi-binder-samples/multi-binder-kafka-streams/src/main/resources/application.yml
+32 -28
View File
@@ -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
multi-binder-samples/multi-binder-kafka-streams/src/test/java/multibinder/TwoKafkaBindersApplicationTest.java
-1
View File
@@ -50,7 +50,6 @@ import static org.hamcrest.Matchers.equalTo;
@SpringBootTest(
webEnvironment = SpringBootTest.WebEnvironment.NONE)
@DirtiesContext
@Ignore
public class TwoKafkaBindersApplicationTest {
@ClassRule