We have requirement to insert a new field that gets populated with the timestamp when kafka message was processed by the connector.
There is no such transform currently available. "InputField" transform provides timestamp.field option but that sets the field value to the timestamp when messaged landed in kafka and not when message was processed by the connector.
Here is the proposal
Enhance InputField transform to add a new option called "processedTimestamp.field" that will allow users to insert new field with value of message processed timestamp as shown in below configuration
here is the potential code block to set this value