package Ġperson op pl ys ning er . n org Ċ Ċ import Ġkotlinx . coroutines . run Blocking Ċ import Ġperson op pl ys ning er . Person op pl ys ning er Ċ import Ġno . nav . a ap . kafka . streams . produce Ċ import Ġorg . apache . kafka . streams . k stream . K Stream Ċ import Ġperson op pl ys ning er . Topics Ċ Ċ internal Ġfun Ġn org Stream ( n org Client : ĠN org Proxy Client ) Ġ= Ġ{ Ġchain : ĠK Stream < String , ĠPerson op pl ys ning er > Ġ-> ĊĠĠĠ Ġchain ĊĠĠĠĠĠĠĠ Ġ. map Values Ġ{ Ġperson op pl ys ning er Ġ-> Ġset t En het ( person op pl ys ning er , Ġn org Client ) Ġ} ĊĠĠĠĠĠĠĠ Ġ. map Values ( Person op pl ys ning er :: to Dto ) ĊĠĠĠĠĠĠĠ Ġ. produce ( Topics . person op pl ys ning er ) Ġ{ Ġ" produce - person op pl ys ning - en het " Ġ} Ċ } Ċ Ċ private Ġfun Ġset t En het ( person : ĠPerson op pl ys ning er , Ġn org Client : ĠN org Proxy Client ): ĠPerson op pl ys ning er Ġ= Ġperson . apply Ġ{ ĊĠĠĠ Ġval Ġrequest Ġ= ĠAr be ids for de ling . create Request ( person . to Dto ()) ĊĠĠĠ Ġval Ġresponse Ġ= Ġrun Blocking Ġ{ Ġn org Client . h ent Ar be ids for de ling ( request ) Ġ} ĊĠĠĠ Ġset t En het ( response . en het Nr ) Ċ } Ċ