Sample kafka streams config cleanup

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

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
+spring.application.name: kafka-streams-branching-sample

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
 
 

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
+spring.cloud.stream.kafka.streams.binder.configuration.application.server: localhost:8080
+spring.applicaiton.name: kafka-streams-iq-advanced-sample

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
+spring.applicaiton.name: kafka-streams-iq-basic-sample

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
-
 
 

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
+spring.applicaiton.name: kafka-streams-product-tracker-sample

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

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
-
-
-
-
-

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