Chapter 71. Timestamp Router Action Update the topic field as a function of the original topic name and the record timestamp. 71.1. Configuration Options The following table summarizes the configuration options available for the timestamp-router-action Kamelet: Property Name Description Type Default Example 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" topicFormat Topic Format Format string which can contain 'USD[topic]' and 'USD[timestamp]' as placeholders for the topic and timestamp, respectively. string "topic-USD[timestamp]" Note Fields marked with an asterisk (*) are mandatory. 71.2. Dependencies At runtime, the timestamp-router-action Kamelet relies upon the presence of the following dependencies: github:openshift-integration.kamelet-catalog:camel-kamelets-utils:kamelet-catalog-1.6-SNAPSHOT camel:kamelet camel:core 71.3. Usage This section describes how you can use the timestamp-router-action . 71.3.1. Knative Action You can use the timestamp-router-action Kamelet as an intermediate step in a Knative binding. timestamp-router-action-binding.yaml apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: timestamp-router-action-binding spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timer-source properties: message: "Hello" steps: - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timestamp-router-action sink: ref: kind: Channel apiVersion: messaging.knative.dev/v1 name: mychannel 71.3.1.1. Prerequisite Make sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you're connected to. 71.3.1.2. Procedure for using the cluster CLI Save the timestamp-router-action-binding.yaml file to your local drive, and then edit it as needed for your configuration. Run the action by using the following command: oc apply -f timestamp-router-action-binding.yaml 71.3.1.3. Procedure for using the Kamel CLI Configure and run the action by using the following command: kamel bind timer-source?message=Hello --step timestamp-router-action channel:mychannel This command creates the KameletBinding in the current namespace on the cluster. 71.3.2. Kafka Action You can use the timestamp-router-action Kamelet as an intermediate step in a Kafka binding. timestamp-router-action-binding.yaml apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: timestamp-router-action-binding spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timer-source properties: message: "Hello" steps: - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timestamp-router-action sink: ref: kind: KafkaTopic apiVersion: kafka.strimzi.io/v1beta1 name: my-topic 71.3.2.1. Prerequisites Ensure that you've installed the AMQ Streams operator in your OpenShift cluster and created a topic named my-topic in the current namespace. Make also sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you're connected to. 71.3.2.2. Procedure for using the cluster CLI Save the timestamp-router-action-binding.yaml file to your local drive, and then edit it as needed for your configuration. Run the action by using the following command: oc apply -f timestamp-router-action-binding.yaml 71.3.2.3. Procedure for using the Kamel CLI Configure and run the action by using the following command: kamel bind timer-source?message=Hello --step timestamp-router-action kafka.strimzi.io/v1beta1:KafkaTopic:my-topic This command creates the KameletBinding in the current namespace on the cluster. 71.4. Kamelet source file https://github.com/openshift-integration/kamelet-catalog/timestamp-router-action.kamelet.yaml

Commands:
apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: timestamp-router-action-binding spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timer-source properties: message: "Hello" steps: - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timestamp-router-action sink: ref: kind: Channel apiVersion: messaging.knative.dev/v1 name: mychannel
apply -f timestamp-router-action-binding.yaml
kamel bind timer-source?message=Hello --step timestamp-router-action channel:mychannel
apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: timestamp-router-action-binding spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timer-source properties: message: "Hello" steps: - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timestamp-router-action sink: ref: kind: KafkaTopic apiVersion: kafka.strimzi.io/v1beta1 name: my-topic
apply -f timestamp-router-action-binding.yaml
kamel bind timer-source?message=Hello --step timestamp-router-action kafka.strimzi.io/v1beta1:KafkaTopic:my-topic