public TimestampType timestampType() {
        return timestampType;
    }
This constructor is intended for use by the Connect runtime only and plugins (sink connectors or transformations)
should not use this directly outside testing code.
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java