Fixing kafka streams sample tests

This commit is contained in:
Soby Chacko
2018-10-11 08:08:38 -04:00
parent ab59cb73c6
commit 12649abfeb

View File

@@ -1,8 +1,10 @@
spring.cloud.stream.bindings.output.contentType: application/json
spring.cloud.stream.kafka.streams.binder.configuration.commit.interval.ms: 1000
spring.cloud.stream.kafka.streams.binder.configuration:
default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
default.value.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
spring.cloud.stream.kafka.streams:
binder.configuration:
default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
default.value.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
bindings.input.consumer.application-id: basic-word-count
spring.cloud.stream.bindings.output:
destination: counts
producer: