diff --git a/kafka-samples/http-ingest/src/main/resources/application.yml b/kafka-samples/http-ingest/src/main/resources/application.yml index 99f4bf6..bd95c19 100644 --- a/kafka-samples/http-ingest/src/main/resources/application.yml +++ b/kafka-samples/http-ingest/src/main/resources/application.yml @@ -2,7 +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 +mappedRequestHeaders: username spring.cloud.stream.bindings.output.producer: messageKeyExpression: headers['username'] useNativeEncoding: true