package Ġk af kas noop Ċ Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Config Ċ import Ġorg . apache . kafka . clients . consumer . Kafka Consumer Ċ import Ġorg . slf 4 j . LoggerFactory Ċ import Ġjava . util . Properties Ċ import Ġjava . util . UUID Ċ Ċ class ĠKafka Client Factory ( private Ġval Ġprops : ĠProperties ) Ġ{ ĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġlogger Ġ= ĠLoggerFactory . getLogger ( Kafka Client Factory :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġcreate Consumer (): ĠKafka Consumer < ByteArray , ĠByteArray > Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġconsumer Id Ġ= Ġ" k af kas noop - consumer -${ UUID . randomUUID () }" ĊĠĠĠĠĠĠĠ Ġlogger . info (" Create Ġconsumer Ġ$ consumer Id ") ĊĠĠĠĠĠĠĠ Ġprops . setProperty ( Consumer Config . CLIENT _ ID _ CONFIG , Ġconsumer Id ) ĊĠĠĠĠĠĠĠ Ġreturn ĠKafka Consumer < ByteArray , ĠByteArray >( props ) ĊĠĠĠ Ġ} Ċ } Ċ