This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 005cb693d566097c4cf5529addd86cf15a7ccbed Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Thu Jan 28 09:28:36 2021 +0100 Fixed CS --- core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java index a1bbb1e..c94ad15 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java @@ -175,9 +175,9 @@ public class CamelSinkTask extends SinkTask { if (header.key().startsWith(HEADER_CAMEL_PREFIX)) { mapHeader(header, HEADER_CAMEL_PREFIX, exchange.getMessage().getHeaders()); } else if (header.key().startsWith(PROPERTY_CAMEL_PREFIX)) { - if (mapProperties) { + if (mapProperties) { mapHeader(header, PROPERTY_CAMEL_PREFIX, exchange.getProperties()); - } + } } }