package Ġno . nav . sy fo . sy k meld ing . kafka . a iven Ċ Ċ import Ġjava . time . Duration Ċ import Ġno . nav . sy fo . sy k meld ing . kafka . a iven . model . Send Sy k meld ing A iven Kafka Message Ċ import Ġorg . apache . kafka . clients . consumer . Kafka Consumer Ċ Ċ class ĠSend t Sy k meld ing A iven Consumer ( ĊĠĠĠ Ġprivate Ġval Ġkafka Consumer : ĠKafka Consumer < String , ĠSend Sy k meld ing A iven Kafka Message >, ĊĠĠĠ Ġprivate Ġval Ġtopic : ĠString Ċ ) Ġ{ ĊĠĠĠ Ġfun Ġpoll (): ĠList < Send Sy k meld ing A iven Kafka Message > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġkafka Consumer . poll ( Duration . of Millis ( 1 0 _ 0 0 0 )). map NotNull Ġ{ Ġit . value () Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġsubscribe () Ġ{ ĊĠĠĠĠĠĠĠ Ġkafka Consumer . subscribe ( listOf ( topic )) ĊĠĠĠ Ġ} Ċ } Ċ