package Ġno . nav . dag p enger . data . ved tak Ċ Ċ import Ġcom . nat pr y ce . kon fig . getValue Ċ import Ġcom . nat pr y ce . kon fig . string Type Ċ import Ġmu . Kotlin Logging Ċ import Ġorg . apache . kafka . clients . producer . Kafka Producer Ċ import Ġorg . apache . kafka . clients . producer . Producer Record ĊĊ Ċ val Ġlog g Ġ= ĠKotlin Logging . logger Ġ{} Ċ Ċ internal Ġclass ĠV ed tak Data Topic ( ĊĠĠĠ Ġprivate Ġval Ġproducer : ĠKafka Producer < String , ĠV ed tak > Ċ ) Ġ{ ĊĠĠĠ Ġprivate Ġval Ġdata _ pro du kt _ topic Ġby Ġstring Type ĊĊĠĠĠ Ġfun Ġpub l iser ( ved tak : ĠV ed tak ) Ġ{ ĊĠĠĠĠĠĠĠ Ġproducer . send ( Producer Record ( config [ data _ pro du kt _ topic ], Ġved tak )) ĊĠĠĠĠĠĠĠ Ġlog g . info Ġ{ Ġ" Send te Ġut Ġved tak Ġmed Ġid : Ġ${ ved tak . ved tak Id } Ġ"} ĊĠĠĠ Ġ} Ċ }