This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch align-timestamp
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 48376a5336f083da55b8aac3f17650329ed8dfeb
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue May 18 11:37:06 2021 +0200
Timestamp Router action updated
---
timestamp-router-action.kamelet.yaml | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/timestamp-router-action.kamelet.yaml
b/timestamp-router-action.kamelet.yaml
index fbe91de..5d55b7e 100644
--- a/timestamp-router-action.kamelet.yaml
+++ b/timestamp-router-action.kamelet.yaml
@@ -17,12 +17,17 @@ spec:
title: Topic Format
description: Format string which can contain '$[topic]' and
'$[timestamp]' as placeholders for the topic and timestamp, respectively.
type: string
- default: "$[topic]-$[timestamp]"
+ default: "topic-$[timestamp]"
timestampFormat:
title: Timestamp Format
description: Format string for the timestamp that is compatible with
java.text.SimpleDateFormat.
type: string
default: "yyyyMMdd"
+ timestampHeaderName:
+ title: Timestamp Header Name
+ description: The name of the header containing a timestamp
+ type: string
+ default: "kafka.TIMESTAMP"
type: object
dependencies:
- github:apache.camel-kamelets:camel-kamelets-utils:main-SNAPSHOT
@@ -38,4 +43,7 @@ spec:
- set-property:
name: "timestampFormat"
constant: "{{timestampFormat}}"
+ - set-property:
+ name: "timestampHeaderName"
+ constant: "{{timestampHeaderName}}"
- bean: "org.apache.camel.kamelets.utils.transform.kafka.TimestampRouter"
