[camel-kamelets] 01/01: Value to Key Action: Use KafkaConstants class for referencing Kafka Key header name

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch kafka-key-ref
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 57fbf1fba4e784270e6ccaa093685eb40ddd6bf1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed May 12 08:43:49 2021 +0200

    Value to Key Action: Use KafkaConstants class for referencing Kafka Key header name
---
 .../org/apache/camel/kamelets/utils/transform/kafka/ValueToKey.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ValueToKey.java b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ValueToKey.java
index 234502b..b4bcf67 100644
--- a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ValueToKey.java
+++ b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/kafka/ValueToKey.java
@@ -22,6 +22,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.camel.Exchange;
 import org.apache.camel.ExchangeProperty;
 import org.apache.camel.InvalidPayloadException;
+import org.apache.camel.component.kafka.KafkaConstants;
 import org.apache.camel.util.ObjectHelper;
 
 import java.util.ArrayList;
@@ -51,7 +52,7 @@ public class ValueToKey {
             }
         }
 
-        ex.getMessage().setHeader("kafka.KEY", key);
+        ex.getMessage().setHeader(KafkaConstants.KEY, key);
     }
 
     boolean filterNames(String fieldName, List<String> splittedFields) {