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

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

commit 3eecd18b42158e4f83ce70a0b61ecec600ce2c8d
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Mar 14 11:01:56 2025 +0100

    Reflect changes from CAMEL-21843 in involved Kamelets - Kafka 
MessageTimestamp
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 kamelets/message-timestamp-router-action.kamelet.yaml                   | 2 +-
 .../resources/kamelets/message-timestamp-router-action.kamelet.yaml     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/kamelets/message-timestamp-router-action.kamelet.yaml 
b/kamelets/message-timestamp-router-action.kamelet.yaml
index f2178c5c..3df2375d 100644
--- a/kamelets/message-timestamp-router-action.kamelet.yaml
+++ b/kamelets/message-timestamp-router-action.kamelet.yaml
@@ -82,7 +82,7 @@ spec:
       - setProperty:
           name: "timestampKeyFormat"
           constant: "{{timestampKeyFormat}}"
-      - bean: 
"org.apache.camel.component.kamelet.utils.transform.MessageTimestampRouter"
+      - bean: 
"org.apache.camel.component.kafka.transform.MessageTimestampRouter"
       - marshal:
           json: 
             library: Jackson
diff --git 
a/library/camel-kamelets/src/main/resources/kamelets/message-timestamp-router-action.kamelet.yaml
 
b/library/camel-kamelets/src/main/resources/kamelets/message-timestamp-router-action.kamelet.yaml
index f2178c5c..3df2375d 100644
--- 
a/library/camel-kamelets/src/main/resources/kamelets/message-timestamp-router-action.kamelet.yaml
+++ 
b/library/camel-kamelets/src/main/resources/kamelets/message-timestamp-router-action.kamelet.yaml
@@ -82,7 +82,7 @@ spec:
       - setProperty:
           name: "timestampKeyFormat"
           constant: "{{timestampKeyFormat}}"
-      - bean: 
"org.apache.camel.component.kamelet.utils.transform.MessageTimestampRouter"
+      - bean: 
"org.apache.camel.component.kafka.transform.MessageTimestampRouter"
       - marshal:
           json: 
             library: Jackson

Reply via email to