package Ġno . nav . kl age . op pg ave . api . controller Ċ Ċ import Ġcom . fasterxml . jackson . module . kotlin . jackson ObjectMapper Ċ import Ġno . fin n . un le ash . Un le ash Ċ import Ġno . nav . kl age . op pg ave . domain . kafka . Kl age ved tak F att et Ċ import Ġno . nav . kl age . op pg ave . service . Admin Service Ċ import Ġno . nav . kl age . op pg ave . service . V ed tak Kafka Producer Ċ import Ġno . nav . kl age . op pg ave . util . getLogger Ċ import Ġno . nav . security . token . support . core . api . Un protected Ċ import Ġorg . springframework . context . annotation . Profile Ċ import Ġorg . springframework . http . HttpStatus Ċ import Ġorg . springframework . web . bind . annotation .* Ċ Ċ @ Profile (" dev - gcp ") Ċ @ RestController Ċ class ĠDev Only AdminController ( ĊĠĠĠ Ġprivate Ġval Ġadmin Service : ĠAdmin Service , ĊĠĠĠ Ġprivate Ġval Ġved tak Kafka Producer : ĠV ed tak Kafka Producer , ĊĠĠĠ Ġprivate Ġval Ġun le ash : ĠUn le ash Ċ ) Ġ{ ĊĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġ@ Suppress (" JAVA _ CLASS _ ON _ COMP AN ION ") ĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġlogger Ġ= Ġget Logger ( java Class . enc lo sing Class ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Un protected ĊĠĠĠ Ġ@ GetMapping ("/ internal / elastic admin / nu ke ", Ġproduces Ġ= Ġ[" application / json "]) ĊĠĠĠ Ġ@ ResponseStatus ( HttpStatus . OK ) ĊĠĠĠ Ġfun Ġreset Elastic Index () Ġ{ ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlogger . info (" Sync ing Ġdb Ġwith ĠKafka ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġadmin Service . sync Kafka With Db () ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlogger . warn (" Failed Ġto Ġres ync Ġdb Ġwith ĠKafka ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthrow Ġe ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Un protected ĊĠĠĠ Ġ@ PostMapping ("/ internal / produce _ kafka _ message ") ĊĠĠĠ Ġ@ ResponseStatus ( HttpStatus . CREATED ) ĊĠĠĠ Ġfun Ġput Result On Kafka Topic ForTesting Pur poses ( ĊĠĠĠĠĠĠĠ Ġ@ RequestBody Ġjson : ĠString ĊĠĠĠ Ġ) Ġ{ ĊĊĠĠĠĠĠĠĠ Ġval Ġkl age ved tak F att et Ġ= Ġj ack son ObjectMapper (). readValue ( json , ĠK lage ved tak F att et :: class . java ) Ċ Ċ // ĠĠĠĠĠĠĠ ĠK lage ved tak F att et ( Ċ // ĠĠĠĠĠĠĠĠĠĠĠ Ġk ilde Refer an se Ġ= Ġ" der es _ ref ", Ċ // ĠĠĠĠĠĠĠĠĠĠĠ Ġk ilde Ġ= Ġ" K 9 ", Ċ // ĠĠĠĠĠĠĠĠĠĠĠ Ġutf all Ġ= ĠUtf all . MED H OLD , Ċ // ĠĠĠĠĠĠĠĠĠĠĠ Ġved t aks bre v Refer an se Ġ= Ġ" journal post _ id _ her ", Ċ // ĠĠĠĠĠĠĠĠĠĠĠ Ġk ab al Refer an se Ġ= Ġ" un ik _ ref _ til _ k ab al " Ċ // ĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ Ġved tak Kafka Producer . send V ed tak ( kl age ved tak F att et ) ĊĠĠĠ Ġ} Ċ }