package Ġno . nav . sy fo . sy k meld ing . kafka . producer Ċ Ċ import Ġno . nav . sy fo . log Ċ import Ġno . nav . sy fo . sy k meld ing . kafka . model . M ott att Sy k meld ing Kafka Message Ċ import Ġorg . apache . kafka . clients . producer . Kafka Producer Ċ import Ġorg . apache . kafka . clients . producer . Producer Record Ċ Ċ class ĠMot t att Sy k meld ing Kafka Producer ( private Ġval Ġkafka Producer : ĠKafka Producer < String , ĠMot t att Sy k meld ing Kafka Message ? >, Ġprivate Ġval Ġtopic : ĠString ) Ġ{ ĊĠĠĠ Ġfun Ġsend M ott att Sy k meld ing ( sy k meld ing Kafka Message : ĠMot t att Sy k meld ing Kafka Message ) Ġ{ ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġkafka Producer . send ( Producer Record ( topic , Ġsy k meld ing Kafka Message . sy k meld ing . id , Ġsy k meld ing Kafka Message )). get () ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlog . error (" K un ne Ġik ke Ġsk rive Ġtil Ġmot t att - topic Ġfor Ġsy k meld ing id Ġ${ sy k meld ing Kafka Message . sy k meld ing . id }: Ġ{}", Ġe . message ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthrow Ġe ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ