package Ġno . nav . person br uk er . dit tn av . event ag gregator . common . kafka . serializer Ċ Ċ import Ġio . con fluent . kafka . sche m are gistry . client . Schema Registry Client Ċ import Ġorg . apache . kafka . common . errors . Serialization Exception Ċ import Ġio . con fluent . kafka . serializers . Kafka Av ro Deserializer Ċ import Ġorg . slf 4 j . Logger Ċ import Ġorg . slf 4 j . LoggerFactory Ċ Ċ /** Ċ Ġ* ĠAv ro Ġde serial iser er Ġsom Ġreturn er er Ġ` null ` Ġh vis Ġden Ġmot tar Ġbytes Ġsom Ġik ke Ġkan Ġde serial iser es Ġtil Ġen ĠAv ro - type . Ċ Ġ* Ċ Ġ* ĠDen ne Ġimplement as jon en Ġer Ġla get Ġfor ĠÃ¥ Ġkun ne Ġign or ere Ġmot tat te Ġevent er Ġsom Ġik ke Ġl ar Ġseg Ġde serial is ere , Ġdet Ġv il Ċ Ġ* Ġbare Ġlog ges Ġat Ġet Ġevent Ġik ke Ġlot Ġseg Ġde serial is ere Ġog Ġdet Ġreturn eres Ġ` null `. ĠDet te Ġg j Ã¸ r Ġat Ġapp ens Ġpoll ere Ġik ke Ċ Ġ* Ġstop per Ġse lv Ġom Ġdet Ġsk ul le Ġkom me Ġet Ġevent Ġsom Ġik ke Ġl ar Ġseg Ġde serial is ere . Ċ Ġ*/ Ċ class ĠSw allow Serialization Errors Av ro Deserializer : ĠKafka Av ro Deserializer Ġ{ ĊĠĠĠ Ġconstructor () Ġ: Ġsuper () ĊĠĠĠ Ġconstructor ( schema Registry Client : ĠSchema Registry Client ) Ġ: Ġsuper ( schema Registry Client ) ĊĠĠĠ Ġconstructor ( schema Registry Client : ĠSchema Registry Client , Ġpro s : ĠMutable Map < String , ĠAny >) Ġ: Ġsuper ( schema Registry Client , Ġpro s ) ĊĊĠĠĠ Ġprivate Ġval Ġlog : ĠLogger Ġ= ĠLoggerFactory . getLogger ( Sw allow Serialization Errors Av ro Deserializer :: class . java ) ĊĊĠĠĠ Ġoverride Ġfun Ġdeserialize ( bytes : ĠByteArray ): ĠAny ? Ġ{ ĊĠĠĠĠĠĠĠ Ġvar Ġresult : ĠAny ? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġresult Ġ= Ġsuper . deserialize ( bytes ) ĊĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠSerialization Exception ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġmsg Ġ= Ġ" Event et Ġkun ne Ġik ke Ġde serial iser es , Ġog Ġb lir Ġfork ast et . ĠDet te Ġsk j ed de Ġme st Ġs ann syn lig Ġfor di Ġevent et Ġik ke Ġvar Ġi Ġh en old Ġtil ĠAv ro - sk j ema et Ġfor Ġden ne Ġtopic - en ." ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlog . error ( msg , Ġe ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġreturn Ġresult ĊĠĠĠ Ġ} Ċ } Ċ