package Ġno . nav . hel se Ċ Ċ import Ġio . con fluent . kafka . serializers . Abstract Kafka Av ro Ser De Config Ċ import Ġorg . apache . kafka . clients . Common Client Configs Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Config Ċ import Ġorg . apache . kafka . clients . consumer . Kafka Consumer Ċ import Ġorg . apache . kafka . common . config . S asl Configs Ċ import Ġjava . util .* ĊĊĊ Ġfun Ġresult at Consumer ( env : ĠEnvironment ): ĠKafka Consumer < String , ĠString > Ġ{ ĊĠĠĠ Ġreturn ĠKafka Consumer ( Properties (). apply Ġ{ ĊĠĠĠĠĠĠĠ Ġput ( Consumer Config . VALUE _ DE SERIAL IZER _ CLASS _ CONFIG , Ġ" org . apache . kafka . common . serialization . String Deserializer ") ĊĠĠĠĠĠĠĠ Ġput ( Consumer Config . KEY _ DE SERIAL IZER _ CLASS _ CONFIG , Ġ" org . apache . kafka . common . serialization . String Deserializer ") ĊĠĠĠĠĠĠĠ Ġput ( Abstract Kafka Av ro Ser De Config . SCHEMA _ REGISTRY _ URL _ CONFIG , ĠValidator Component Test . embedded Environment . schema Registry !!. url ) ĊĠĠĠĠĠĠĠ Ġput ( Consumer Config . GROUP _ ID _ CONFIG , Ġ" ved tak . result . test ") ĊĠĠĠĠĠĠĠ Ġput ( Consumer Config . BOOT STR AP _ SERVER S _ CONFIG , ĠValidator Component Test . embedded Environment . bro kers URL ) ĊĠĠĠĠĠĠĠ Ġput ( Common Client Configs . SECURITY _ PROTOCOL _ CONFIG , Ġ" SAS L _ PL AINT EXT ") ĊĠĠĠĠĠĠĠ Ġput ( S asl Configs . SAS L _ ME CHAN IS M , Ġ" PLAIN ") ĊĠĠĠĠĠĠĠ Ġput ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠS asl Configs . SAS L _ JA AS _ CONFIG , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" org . apache . kafka . common . security . plain . Plain Login Module Ġrequired Ġusername =\" ${ env . username }\" Ġpassword =\" ${ env . password }\ "; " ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ}) Ċ }