Missing timestamp information

[hguerrero]

The connectors like the Timer one, are missing the information regarding Timestamp. So, when trying to use a transformation like InsertField timestamp.field it won't work as the information is missing.

Example:

{
    "name": "timer",
    "config": {
        "connector.class": "org.apache.camel.kafkaconnector.timer.CamelTimerSourceConnector",
        "topics": "camel.timer.1",
        "camel.source.path.timerName": "timer",
        "key.converter": "org.apache.kafka.connect.storage.StringConverter",
        "value.converter": "org.apache.kafka.connect.json.JsonConverter",
        "value.converter.schemas.enable": "false",
        "tasks.max": "1",
        "transforms": "HoistField,InsertField",
        "transforms.HoistField.type": "org.apache.kafka.connect.transforms.HoistField$Value",
        "transforms.HoistField.field": "timer",
        "transforms.InsertField.type": "org.apache.kafka.connect.transforms.InsertField$Value",
        "transforms.InsertField.timestamp.field": "ts"
    }
}

[oscerd]

If you print the source record coming from a timer there will be a timestamp with CamelHeader.* as prefix

[oscerd]

You need to check the record headers