public Long getTimestamp ( ) { Object timestamp = getHeader ( KafkaMessageHeaders . TIMESTAMP ) ; if ( timestamp != null ) { return Long . valueOf ( timestamp . toString ( ) ) ; } return null ; }
Gets the Kafka timestamp header .