Page History

public SinkRecord(String topic, int partition, Schema keySchema, Object key, Schema valueSchema, Object value, long kafkaOffset, longLong timestamp, TimestampType timestampType) { .. }
  
public TimestampType timestampType() { .. }
  
public Long timestamp() { .. }