package Ġru . dat ana . smart . common . ktor . kafka Ċ Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Records Ċ import Ġjava . time . Instant Ċ Ċ class ĠConsumer Item < K , V >( ĊĠĠĠ Ġval Ġtime : ĠInstant , ĊĠĠĠ Ġval Ġkey : ĠK , ĊĠĠĠ Ġval Ġvalue : ĠV , ĊĠĠĠ Ġval Ġtopic : ĠString , ĊĠĠĠ Ġval Ġpartition : ĠInt , ĊĠĠĠ Ġval Ġoffset : ĠLong , ĊĠĠĠ Ġval Ġheaders : ĠMap < String , ĠByteArray > Ċ ) Ċ Ċ class ĠConsumer Items < K , V >( val Ġitems : ĠSequence < Consumer Item < K , V >>) Ġ{ ĊĠĠĠ Ġconstructor ( records : ĠConsumer Records < K , V >) Ġ: Ġthis ( ĊĠĠĠĠĠĠĠ Ġrecords ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. as Sequence () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠConsumer Item ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġtime Ġ= ĠInstant . of Epoch Milli ( it . timestamp ()), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġkey Ġ= Ġit . key (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġvalue Ġ= Ġit . value (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġtopic Ġ= Ġit . topic (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġpartition Ġ= Ġit . partition (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġoffset Ġ= Ġit . offset (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġheaders Ġ= Ġit ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. headers () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġit . key () Ġto Ġit . value () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. toMap () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ) Ċ } Ċ