package Ġno . nav . hel se . flex . j ur id isk v ur der ing Ċ Ċ import Ġcom . fasterxml . jackson . module . kotlin . readValue Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Record Ċ import Ġorg . springframework . kafka . annotation . Kafka Listener Ċ import Ġorg . springframework . kafka . support . Ack nowled gment Ċ import Ġorg . springframework . stereotype . Component Ċ import Ġjava . time . Offset DateTime Ċ Ċ @ Component Ċ class ĠJ ur id isk V ur der ing Listener ( ĊĠĠĠ Ġprivate Ġval Ġj ur id isk V ur der ing Repository : ĠJ ur id isk V ur der ing Repository , Ċ ) Ġ{ ĊĊĠĠĠ Ġval Ġlog Ġ= Ġlogger () ĊĊĠĠĠ Ġ@ Kafka Listener ( ĊĠĠĠĠĠĠĠ Ġtopics Ġ= Ġ[" flex . om r ade - hel se - et ter level se "], ĊĠĠĠĠĠĠĠ Ġid Is Group Ġ= Ġfalse , ĊĠĠĠĠĠĠĠ Ġcontainer Factory Ġ= Ġ" a iven Kafka Listener Container Factory ", ĊĠĠĠ Ġ) ĊĠĠĠ Ġfun Ġlisten ( cr : ĠConsumer Record < String , ĠString >, Ġacknowled gment : ĠAck nowled gment ) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġkey Ġ= Ġcr . key () ĊĠĠĠĠĠĠĠ Ġval Ġvalue Ġ= Ġcr . value () ĊĊĠĠĠĠĠĠĠ Ġdata Ġclass ĠF el ter F ra V ur der ing ( val Ġpar agr af : ĠString , Ġval Ġutf all : ĠString ) ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( key . er Fn r ()) Ġ{ ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġde serial is ert : ĠF el ter F ra V ur der ing Ġ= ĠobjectMapper . readValue ( value ) ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġj ur id isk V ur der ing Repository . save ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠJ ur id isk V ur der ing Db Record ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġid Ġ= Ġnull , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġfn r Ġ= Ġkey , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġopp rett et Ġ= ĠOffset DateTime . now (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġj ur id isk V ur der ing Ġ= Ġvalue , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġpar agr af Ġ= Ġde serial is ert . par agr af , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġutf all Ġ= Ġde serial is ert . utf all , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġlog . error (" Key ĠpÃ¥ Ġkafka Ġer Ġik ke Ġfn r : Ġ$ key Ġ, Ġhe le Ġme ld ingen : Ġ$ value ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlog . error (" Fe il Ġved Ġpro sse ser ing Ġav Ġme ld ing ĠpÃ¥ Ġkafka . Ġden ne Ġfork ast es . Ġ$ key Ġ- Ġ$ value Ġ", Ġe ) ĊĠĠĠĠĠĠĠ Ġ} Ġfinally Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġacknowled gment . ack nowledge () ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ