package Ġno . nav . person br uk er . internal . periodic . metrics . reporter . metrics . kafka . topic Ċ Ċ import Ġno . nav . br uk er not ifik as jon . schemas . internal . N ok kel Intern Ċ import Ġno . nav . person br uk er . internal . periodic . metrics . reporter . metrics . kafka . Kafka Event Identifier Ċ import Ġorg . apache . avro . generic . Generic Record Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Record Ċ import Ġorg . slf 4 j . LoggerFactory Ċ Ċ object ĠKafka Key Identifier Transformer Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġlog Ġ= ĠLoggerFactory . getLogger ( Kafka Key Identifier Transformer :: class . java ) ĊĊĠĠĠ Ġfun Ġ< K > Ġto Internal ( external : ĠConsumer Record < K , ĠGeneric Record >): ĠKafka Event Identifier Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġkey Ġ= Ġexternal . key () ĊĊĠĠĠĠĠĠĠ Ġreturn Ġwhen Ġ( key ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġnull Ġ-> Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġinvalid Event Ġ= ĠKafka Event Identifier . create Invalid Event () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġlog . warn (" K an Ġik ke Ġt elle Ġevent et , Ġfor di Ġkafka - key Ġ( N ok kel ) Ġer Ġnull . ĠTransformer er Ġtil Ġet Ġdummy - event : Ġ$ invalid Event .") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġinvalid Event ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġis ĠN ok kel Intern Ġ-> Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠKafka Event Identifier ( key . getEvent Id (), Ġkey . getName space (), Ġkey . getApp nav n ()) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġelse Ġ-> Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġinvalid Event Ġ= ĠKafka Event Identifier . create Invalid Event () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġlog . warn (" K an Ġik ke Ġt elle Ġevent et , Ġfor di Ġkafka - key Ġ( N ok kel ) Ġer Ġav Ġuk j ent Ġtype . ĠTransformer er Ġtil Ġet Ġdummy - event : Ġ$ invalid Event .") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġinvalid Event ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ