package Ġno . nav . hel se . spark er Ċ Ċ import Ġorg . apache . kafka . clients . Common Client Configs Ċ import Ġorg . apache . kafka . clients . producer . Producer Config Ċ import Ġorg . apache . kafka . common . config . Ssl Configs Ċ import Ġjava . util .* Ċ Ċ class ĠKafka Config ( ĊĠĠĠ Ġprivate Ġval Ġbootstrap Servers : ĠString , ĊĠĠĠ Ġprivate Ġval Ġtrust store : ĠString , ĊĠĠĠ Ġprivate Ġval Ġtrust store Password : ĠString , ĊĠĠĠ Ġprivate Ġval Ġkeystore Location : ĠString , ĊĠĠĠ Ġprivate Ġval Ġkeystore Password : ĠString Ċ ) Ġ{ ĊĠĠĠ Ġinternal Ġfun Ġproducer Config () Ġ= Ġkafka Base Config (). apply Ġ{ ĊĠĠĠĠĠĠĠ Ġput ( Producer Config . ACK S _ CONFIG , Ġ" 1 ") ĊĠĠĠĠĠĠĠ Ġput ( Producer Config . CLIENT _ ID _ CONFIG , Ġ" spark er - alt - v 1 ") ĊĠĠĠĠĠĠĠ Ġput ( Producer Config . LING ER _ MS _ CONFIG , Ġ" 0 ") ĊĠĠĠĠĠĠĠ Ġput ( Producer Config . RE TR IES _ CONFIG , ĠInt . MAX _ VALUE ) ĊĠĠĠĠĠĠĠ Ġput ( Producer Config . MAX _ IN _ FL IGHT _ REQUEST S _ PER _ CONNECTION , Ġ" 1 ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġkafka Base Config () Ġ= ĠProperties (). apply Ġ{ ĊĠĠĠĠĠĠĠ Ġput ( Common Client Configs . BOOT STR AP _ SERVER S _ CONFIG , Ġbootstrap Servers ) ĊĠĠĠĠĠĠĠ Ġput ( Common Client Configs . SECURITY _ PROTOCOL _ CONFIG , Ġ" SSL ") ĊĠĠĠĠĠĠĠ Ġput ( Ssl Configs . SSL _ ENDPOINT _ IDENT IFICATION _ ALGORITHM _ CONFIG , Ġ"") ĊĠĠĠĠĠĠĠ Ġput ( Ssl Configs . SSL _ TR UST STORE _ LOCATION _ CONFIG , Ġtrust store ) ĊĠĠĠĠĠĠĠ Ġput ( Ssl Configs . SSL _ TR UST STORE _ PASSWORD _ CONFIG , Ġtrust store Password ) ĊĠĠĠĠĠĠĠ Ġput ( Ssl Configs . SSL _ KEY STORE _ LOCATION _ CONFIG , Ġkeystore Location ) ĊĠĠĠĠĠĠĠ Ġput ( Ssl Configs . SSL _ KEY STORE _ PASSWORD _ CONFIG , Ġkeystore Password ) ĊĠĠĠ Ġ} Ċ } Ċ