package Ġno . nav . su . meld inger . kafka Ċ Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Record Ċ import Ġorg . apache . kafka . clients . producer . Producer Record Ċ import Ġorg . apache . kafka . common . header . Headers Ċ Ċ fun ĠConsumer Record < String , ĠString >. headers AsString (): ĠMap < String , ĠString > Ġ= Ġget Headers AsString ( this . headers ()) Ċ fun ĠProducer Record < String , ĠString >. headers AsString (): ĠMap < String , ĠString > Ġ= Ġget Headers AsString ( this . headers ()) Ċ Ċ private Ġfun Ġget Headers AsString ( headers : ĠHeaders ): ĠMutable Map < String , ĠString > Ġ{ ĊĠĠĠ Ġval Ġmap Ġ= Ġmutable Map Of < String , ĠString >() ĊĠĠĠ Ġheaders . forEach Ġ{ ĊĠĠĠĠĠĠĠ Ġmap [ it . key ()] Ġ= ĠString ( it . value ()) ĊĠĠĠ Ġ} ĊĠĠĠ Ġreturn Ġmap Ċ }