package Ġno . nav . sy fo . op pf ol ging st il f elle . person . kafka Ċ Ċ import Ġno . nav . sy fo . op pf ol ging st il f elle . person . domain . Opp fol ging st il f elle Person Ċ import Ġno . nav . sy fo . op pf ol ging st il f elle . person . domain . to Kafka Opp fol ging st il f elle Person Ċ import Ġorg . apache . kafka . clients . producer . Kafka Producer Ċ import Ġorg . apache . kafka . clients . producer . Producer Record Ċ import Ġorg . slf 4 j . LoggerFactory Ċ import Ġjava . util .* Ċ Ċ class ĠO pp fol ging st il f elle Person Producer ( ĊĠĠĠ Ġprivate Ġval Ġkafka Producer Opp fol ging st il f elle : ĠKafka Producer < String , ĠKafka Opp fol ging st il f elle Person >, Ċ ) Ġ{ ĊĠĠĠ Ġfun Ġsend Opp fol ging st il f elle Person ( ĊĠĠĠĠĠĠĠ Ġopp fol ging st il f elle Person : ĠO pp fol ging st il f elle Person , ĊĠĠĠ Ġ) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġkafka Opp fol ging st il f elle Person Ġ= Ġopp fol ging st il f elle Person . to Kafka Opp fol ging st il f elle Person () ĊĠĠĠĠĠĠĠ Ġval Ġkey Ġ= ĠUUID . name UUID From Bytes ( kafka Opp fol ging st il f elle Person . person Ident Number . toByteArray ()). toString () ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġkafka Producer Opp fol ging st il f elle . send ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠProducer Record ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠO PP FOL GING ST IL F EL LE _ TOPIC , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġkey , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġkafka Opp fol ging st il f elle Person , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ). get () ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlog . error ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" Exception Ġwas Ġthrown Ġwhen Ġattempting Ġto Ġsend ĠKafka Opp fol ging st il f elle Ġwith Ġid Ġ{} : Ġ${ e . message }", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġkey ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthrow Ġe ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġconst Ġval ĠO PP FOL GING ST IL F EL LE _ TOPIC Ġ= Ġ" teams y ke fr avr . is op pf ol ging st il f elle - op pf ol ging st il f elle - person " ĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġlog Ġ= ĠLoggerFactory . getLogger ( Opp fol ging st il f elle Person Producer :: class . java ) ĊĠĠĠ Ġ} Ċ } Ċ