From 3f59cea677a580d4b7e05db7db56a83212b908c9 Mon Sep 17 00:00:00 2001 From: Ilayaperumal Gopinathan Date: Tue, 26 Mar 2019 09:04:56 +0530 Subject: [PATCH] Fix http-ingest mappedRequestHeader prefix and binding props --- .../http-ingest/src/main/resources/application.yml | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/kafka-samples/http-ingest/src/main/resources/application.yml b/kafka-samples/http-ingest/src/main/resources/application.yml index bd95c19..cb96f97 100644 --- a/kafka-samples/http-ingest/src/main/resources/application.yml +++ b/kafka-samples/http-ingest/src/main/resources/application.yml @@ -1,8 +1,10 @@ +http: + mapped-request-headers: username +spring.cloud.stream.kafka.bindings.output.producer: + messageKeyExpression: headers['username'] +spring.cloud.stream.bindings.output.producer: + useNativeEncoding: true 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 -mappedRequestHeaders: username -spring.cloud.stream.bindings.output.producer: - messageKeyExpression: headers['username'] - useNativeEncoding: true