Example

This example replaces the timestamp on a record with the current timestamp.

Input

{
  "topic" : "test",
  "kafkaPartition" : 1,
  "key" : "",
  "value" : "",
  "timestamp" : 12341312,
  "timestampType" : "NO_TIMESTAMP_TYPE",
  "offset" : 1234123,
  "headers" : [ ]
}

Change(s) in the output are emphasized if delta(s) are detected.

Output

{
  "topic" : "test",
  "kafkaPartition" : 1,
  "key" : "",
  "value" : "",
  "timestamp" : 1665683591817,
  "timestampType" : "NO_TIMESTAMP_TYPE",
  "offset" : 1234123,
  "headers" : [ ]
}