[camel-kamelets] branch main updated: Value to Key Action: Use KafkaConstants class for referencing Kafka Key header name

[acosentino]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 6dae8f7  Value to Key Action: Use KafkaConstants class for referencing 
Kafka Key header name
6dae8f7 is described below

commit 6dae8f77b26c48609fc0cc48eb1222b151d46ce8
Author: Andrea Cosentino <anco...@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) {