[camel-kamelets] branch main updated: Added first implementation of ValueToKey transforms

[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 2ef654f  Added first implementation of ValueToKey transforms
2ef654f is described below

commit 2ef654f0a3dc447458affb2e03fe0575d8928f1b
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed May 5 11:52:46 2021 +0200

    Added first implementation of ValueToKey transforms
---
 .../apache/camel/kamelets/utils/transform/kafka/ValueToKey.java   | 8 +++++++-
 1 file changed, 7 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 d8c0aaa..39ae090 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
@@ -32,7 +32,13 @@ public class ValueToKey {
 
     public void process(@ExchangeProperty("fields") String fields, Exchange 
ex) throws InvalidPayloadException {
         List<String> splittedFields = new ArrayList<>();
-        Map<Object, Object> body = ex.getMessage().getMandatoryBody(Map.class);
+        Map<Object, Object> body = ex.getMessage().getBody(Map.class);
+        if (body == null) {
+            String val = ex.getMessage().getMandatoryBody(String.class);
+            body = new HashMap<>();
+            // TODO: make this configurable
+            body.put("content", val);
+        }
         if (ObjectHelper.isNotEmpty(fields)) {
             splittedFields = 
Arrays.stream(fields.split(",")).collect(Collectors.toList());
         }