Update the topic field as a function of the original topic name and the record's timestamp field.
Metadata
Property
Value
Type
action
Group
Actions
Namespace
Kafka
Support Level
Stable
Provider
Apache Software Foundation
Properties
Name
Type
Required
Default
Description
topicFormat
string
topic-$[timestamp]
Format string which can contain '$[topic]' and '$[timestamp]' as placeholders for the topic and timestamp, respectively.
timestampFormat
string
yyyyMMdd
Format string for the timestamp that is compatible with java.text.SimpleDateFormat.
timestampKeys
string
✓
Comma separated list of Timestamp keys. The timestamp is taken from the first found field.
timestampKeyFormat
string
timestamp
Format of the timestamp keys. Possible values are 'timestamp' or any format string for the timestamp that is compatible with java.text.SimpleDateFormat. In case of 'timestamp' the field will be evaluated as milliseconds since 1970, so as a UNIX Timestamp.
Dependencies
camel:jackson
camel:kamelet
camel:core
Delete Page
Deleting the wiki page "Home" cannot be undone. Continue?