package Ġio . kf leet . domain Ċ Ċ import Ġio . kf leet . commands . Command Response Ċ import Ġorg . apache . avro . specific . Specific Record Ċ import Ġorg . apache . kafka . streams . KeyValue Ċ Ċ @ Retention ( Annotation Retention . RUNTIME ) Ċ @ Target (( Annotation Target . CLASS )) Ċ annotation Ġclass ĠOwner Command Ċ Ċ fun Ġcommand Response ( build Command Response : ĠCommand Response . Builder . () Ġ-> ĠUnit ): ĠCommand Response Ġ= ĊĠĠĠĠĠĠĠ ĠCommand Response . newBuilder (). apply Ġ{ Ġbuild Command Response () Ġ}. build () ĊĊ Ċ fun ĠCommand Response . as KeyValue (): ĠKey Value < String , ĠSpecific Record ?> Ġ{ ĊĠĠĠ Ġreturn ĠKey Value ( this . get Command Id (), Ġthis ) Ċ } Ċ