Fixed CS

apache · Jan 28, 2021 · 005cb69 · 005cb69
1 parent a108cf1
commit 005cb69
Showing 1 changed file with 2 additions and 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
@@ -175,9 +175,9 @@ public void put(Collection<SinkRecord> sinkRecords) {
                 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());
-                	}
+                    }
                 }
             }