From a2440faf3abd1da915122464f00b6880b184c188 Mon Sep 17 00:00:00 2001 From: Ilayaperumal Gopinathan Date: Tue, 26 Mar 2019 00:01:34 +0530 Subject: [PATCH] Fix http-ingest to have default values - update common header values --- kafka-samples/http-ingest/src/main/resources/application.yml | 2 ++ 1 file changed, 2 insertions(+) diff --git a/kafka-samples/http-ingest/src/main/resources/application.yml b/kafka-samples/http-ingest/src/main/resources/application.yml index 935d488..99f4bf6 100644 --- 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