Chapter 79. Timestamp Router Action
Update the topic field as a function of the original topic name and the record timestamp.
79.1. Configuration Options Copy linkLink copied to clipboard!
The following table summarizes the configuration options available for the timestamp-router-action Kamelet:
| Property | Name | Description | Type | Default | Example |
|---|---|---|---|---|---|
| topicFormat | Topic Format | Format string which can contain '$[topic]' and '$[timestamp]' as placeholders for the topic and timestamp, respectively. | string | topic-$[timestamp] | |
| timestampFormat | Timestamp Format | Format string for the timestamp that is compatible with java.text.SimpleDateFormat. | string | yyyyMMdd | |
| timestampHeaderName | Timestamp Header Name | The name of the header containing a timestamp | string | kafka.TIMESTAMP |
* = Fields marked with an asterisk are mandatory.
79.2. Dependencies Copy linkLink copied to clipboard!
79.2.1. Quarkus dependencies Copy linkLink copied to clipboard!
79.3. Usage Copy linkLink copied to clipboard!
79.3.1. Camel JBang usage Copy linkLink copied to clipboard!
79.3.1.1. Prerequisites for JBang Copy linkLink copied to clipboard!
- Install JBang.
You have executed the following command:
jbang app install camel@apache/camel
jbang app install camel@apache/camelCopy to Clipboard Copied! Toggle word wrap Toggle overflow
79.3.1.2. Running a route with JBang Copy linkLink copied to clipboard!
Suppose you have a file named route.yaml with this content:
You can now run it directly through the following command.
camel run route.yaml
camel run route.yaml
79.3.2. Knative Action Copy linkLink copied to clipboard!
You can use the timestamp-router-action Kamelet as an intermediate step in a Knative binding.
timestamp-router-action-binding.yaml
79.3.3. Kafka Action Copy linkLink copied to clipboard!
You can use the timestamp-router-action Kamelet as an intermediate step in a Kafka binding.
timestamp-router-action-binding.yaml