package Ġcom . info bip . k af k ist ry . service . ol dest record age Ċ Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Record Ċ Ċ interface ĠRecord Timestamp Extractor Ġ{ ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠTry Ġto Ġextract Ġtimestamp Ġin Ġmilliseconds Ġfrom Ġconsumer Ġrecord . ĊĠĠĠĠ Ġ* ĊĠĠĠĠ Ġ* ĠImplementation Ġis Ġable Ġto Ġextract Ġtimestamp Ġfrom Ġspecific Ġheaders Ġor Ġeven Ġmessage Ġpayload ĊĠĠĠĠ Ġ* Ġ( depend ing Ġon Ġbusiness Ġmeaning ). ĊĠĠĠĠ Ġ* ĠP refer Ġreturning Ġ` null ` Ġinstead Ġof Ġthrowing Ġan Ġexception Ġas Ġsignal Ġfor ĊĠĠĠĠ Ġ* Ġ" unable Ġto Ġextract Ġtimestamp Ġfrom Ġparticular Ġrecord ". ĊĠĠĠĠ Ġ* ĊĠĠĠĠ Ġ* Ġ@ return Ġextracted Ġtimestamp Ġepoch Ġmillis Ġor Ġ` null ` Ġif Ġunable Ġto Ġextract . ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġfun Ġextract Timestamp From ( consumer Record : ĠConsumer Record < ByteArray ?, ĠByteArray ?> ): ĠLong ? ĊĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġval ĠNONE Ġ= Ġobject Ġ: ĠRecord Timestamp Extractor Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġextract Timestamp From ( consumer Record : ĠConsumer Record < ByteArray ?, ĠByteArray ?> ): ĠLong ? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }