Fix http-ingest to have default values

- update common header values
2019-03-26 00:01:34 +05:30
parent 923b057c18
commit a2440faf3a
1 changed files with 2 additions and 0 deletions
--- a/kafka-samples/http-ingest/src/main/resources/application.yml
+++ b/kafka-samples/http-ingest/src/main/resources/application.yml
@@ -2,5 +2,7 @@ spring.cloud.stream.kafka.binder.configuration.key:
  serializer: org.apache.kafka.common.serialization.StringSerializer
 spring.cloud.stream.kafka.binder.configuration.value:
  serializer: org.apache.kafka.common.serialization.StringSerializer
+mapped-request-headers: username
 spring.cloud.stream.bindings.output.producer:
+  messageKeyExpression: headers['username']
  useNativeEncoding: true