diff --git a/kafka-streams-samples/kafka-streams-aggregate/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-aggregate/src/main/resources/application.yml index e34d2c9..c61f156 100644 --- a/kafka-streams-samples/kafka-streams-aggregate/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-aggregate/src/main/resources/application.yml @@ -1,10 +1,9 @@ +spring.application.name: kafka-streams-aggregate-sample spring.cloud.stream.bindings.input: destination: foobar consumer: - headerMode: raw spring.cloud.stream.kafka.streams.binder: brokers: localhost #192.168.99.100 - zkNodes: localhost #192.168.99.100 configuration: default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde default.value.serde: org.apache.kafka.common.serialization.Serdes$BytesSerde diff --git a/kafka-streams-samples/kafka-streams-branching/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-branching/src/main/resources/application.yml index e706fc6..4546d9d 100644 --- a/kafka-streams-samples/kafka-streams-branching/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-branching/src/main/resources/application.yml @@ -8,20 +8,16 @@ spring.cloud.stream.kafka.streams.binder.configuration: spring.cloud.stream.bindings.output1: destination: english-counts producer: - headerMode: raw spring.cloud.stream.bindings.output2: destination: french-counts producer: - headerMode: raw spring.cloud.stream.bindings.output3: destination: spanish-counts producer: - headerMode: raw spring.cloud.stream.bindings.input: destination: words group: group1 consumer: - headerMode: raw spring.cloud.stream.kafka.streams.binder: brokers: localhost #192.168.99.100 #localhost - zkNodes: localhost #192.168.99.100 #localhost \ No newline at end of file +spring.application.name: kafka-streams-branching-sample \ No newline at end of file diff --git a/kafka-streams-samples/kafka-streams-dlq-sample/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-dlq-sample/src/main/resources/application.yml index 4d8a6b3..dcd00ff 100644 --- a/kafka-streams-samples/kafka-streams-dlq-sample/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-dlq-sample/src/main/resources/application.yml @@ -7,18 +7,15 @@ spring.cloud.stream.kafka.streams.binder.configuration: spring.cloud.stream.bindings.output: destination: counts producer: - headerMode: raw #useNativeEncoding: true spring.cloud.stream.bindings.input: destination: words group: group1 consumer: - headerMode: raw useNativeDecoding: true spring.cloud.stream.kafka.streams.bindings.input.consumer.dlqName: words-count-dlq spring.cloud.stream.kafka.streams.binder: brokers: localhost #192.168.99.100 - zkNodes: localhost #192.168.99.100 serdeError: sendToDlq diff --git a/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/resources/application.yml index ddc0196..9e8c880 100644 --- a/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/resources/application.yml @@ -2,12 +2,10 @@ spring.cloud.stream.bindings.input: destination: play-events consumer: useNativeDecoding: true - headerMode: raw spring.cloud.stream.bindings.inputX: destination: song-feed consumer: useNativeDecoding: true - headerMode: raw spring.cloud.stream.kafka.streams.bindings.input: consumer: keySerde: org.apache.kafka.common.serialization.Serdes$StringSerde @@ -19,10 +17,10 @@ spring.cloud.stream.kafka.streams.bindings.inputX: materializedAs: all-songs spring.cloud.stream.kafka.streams.binder: brokers: localhost #192.168.99.100 - zkNodes: localhost #192.168.99.100 configuration: schema.registry.url: http://localhost:8081 commit.interval.ms: 1000 spring.cloud.stream.kafka.streams.binder.autoAddPartitions: true spring.cloud.stream.kafka.streams.binder.minPartitionCount: 4 -spring.cloud.stream.kafka.streams.binder.configuration.application.server: localhost:8080 \ No newline at end of file +spring.cloud.stream.kafka.streams.binder.configuration.application.server: localhost:8080 +spring.applicaiton.name: kafka-streams-iq-advanced-sample \ No newline at end of file diff --git a/kafka-streams-samples/kafka-streams-interactive-query-basic/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-interactive-query-basic/src/main/resources/application.yml index 5ba82d0..920cbfe 100644 --- a/kafka-streams-samples/kafka-streams-interactive-query-basic/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-interactive-query-basic/src/main/resources/application.yml @@ -10,12 +10,10 @@ spring.cloud.stream.kafka.streams: spring.cloud.stream.bindings.output: destination: product-counts producer: - headerMode: raw useNativeEncoding: true spring.cloud.stream.bindings.input: destination: products consumer: - headerMode: raw spring.cloud.stream.kafka.streams.binder: brokers: localhost #192.168.99.100 - zkNodes: localhost #192.168.99.100 \ No newline at end of file +spring.applicaiton.name: kafka-streams-iq-basic-sample \ No newline at end of file diff --git a/kafka-streams-samples/kafka-streams-message-channel/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-message-channel/src/main/resources/application.yml index 3db7566..42d49fa 100644 --- a/kafka-streams-samples/kafka-streams-message-channel/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-message-channel/src/main/resources/application.yml @@ -6,19 +6,15 @@ spring.cloud.stream.kafka.streams.binder.configuration: spring.cloud.stream.bindings.singleOutput: destination: counts producer: - headerMode: raw #useNativeEncoding: true spring.cloud.stream.bindings.binding2: destination: words consumer: - headerMode: raw spring.cloud.stream.bindings.binding1: destination: words consumer: - headerMode: raw spring.cloud.stream.kafka.streams.binder: brokers: localhost #192.168.99.100 - zkNodes: localhost #192.168.99.100 - +spring.applicaiton.name: kafka-streams-message-channel-sample diff --git a/kafka-streams-samples/kafka-streams-product-tracker/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-product-tracker/src/main/resources/application.yml index 11b9f51..0f9a790 100644 --- a/kafka-streams-samples/kafka-streams-product-tracker/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-product-tracker/src/main/resources/application.yml @@ -9,12 +9,10 @@ spring.cloud.stream.kafka.streams: spring.cloud.stream.bindings.output: destination: product-counts producer: - headerMode: raw #useNativeEncoding: true spring.cloud.stream.bindings.input: destination: products consumer: - headerMode: raw spring.cloud.stream.kafka.streams.binder: brokers: localhost #192.168.99.100 - zkNodes: localhost #192.168.99.100 \ No newline at end of file +spring.applicaiton.name: kafka-streams-product-tracker-sample \ No newline at end of file diff --git a/kafka-streams-samples/kafka-streams-table-join/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-table-join/src/main/resources/application.yml index 786a0bb..e1d85b3 100644 --- a/kafka-streams-samples/kafka-streams-table-join/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-table-join/src/main/resources/application.yml @@ -3,18 +3,15 @@ spring.cloud.stream.bindings.input: destination: user-clicks3 consumer: useNativeDecoding: true - headerMode: raw spring.cloud.stream.bindings.inputTable: destination: user-regions contentType: application/avro consumer: useNativeDecoding: true - headerMode: raw spring.cloud.stream.bindings.output: destination: output-topic producer: useNativeEncoding: true - headerMode: raw spring.cloud.stream.kafka.streams.bindings.input: consumer: keySerde: org.apache.kafka.common.serialization.Serdes$StringSerde @@ -29,7 +26,6 @@ spring.cloud.stream.kafka.streams.bindings.output: valueSerde: org.apache.kafka.common.serialization.Serdes$LongSerde spring.cloud.stream.kafka.streams.binder: brokers: localhost #192.168.99.100 - zkNodes: localhost #192.168.99.100 configuration: default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde default.value.serde: org.apache.kafka.common.serialization.Serdes$StringSerde diff --git a/kafka-streams-samples/kafka-streams-to-rabbitmq-message-channel/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-to-rabbitmq-message-channel/src/main/resources/application.yml index a21f163..cb66c11 100644 --- a/kafka-streams-samples/kafka-streams-to-rabbitmq-message-channel/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-to-rabbitmq-message-channel/src/main/resources/application.yml @@ -22,8 +22,3 @@ spring.cloud.stream.bindings.testInputFromRabbit: spring.cloud.stream.kafka.streams.binder: brokers: localhost - - - - - diff --git a/kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml b/kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml index 98a7063..a656139 100644 --- a/kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml +++ b/kafka-streams-samples/kafka-streams-word-count/src/main/resources/application.yml @@ -8,12 +8,10 @@ spring.cloud.stream.kafka.streams: spring.cloud.stream.bindings.output: destination: counts producer: - headerMode: raw #useNativeEncoding: true spring.cloud.stream.bindings.input: destination: words consumer: - headerMode: raw #For testing spring.cloud.stream.bindings.input1.destination: counts spring.cloud.stream.bindings.output1.destination: words