public Long getOffset ( ) { Object offset = getHeader ( KafkaMessageHeaders . OFFSET ) ; if ( offset != null ) { return TypeConversionUtils . convertIfNecessary ( offset , Long . class ) ; } return 0L ; }
Gets the Kafka offset header .