package Ġfund . cyber . common . kafka Ċ Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Config Ċ import Ġorg . apache . kafka . clients . producer . Producer Config Ċ Ċ const Ġval ĠK AF KA _ MAX _ MESSAGE _ SIZE _ BYTES Ġ= Ġ 1 5 7 2 8 6 4 0 Ċ const Ġval ĠSESSION _ TIMEOUT _ MS _ CONFIG Ġ= Ġ 3 0 0 0 0 Ċ const Ġval ĠDEFAULT _ POLL _ TIMEOUT Ġ= Ġ 5 0 0 0 L Ċ Ċ fun Ġdefault Consumer Config () Ġ= Ġmutable Map Of < String , ĠAny >( ĊĠĠĠ ĠConsumer Config . MAX _ PARTITION _ FETCH _ BYTES _ CONFIG Ġto ĠK AF KA _ MAX _ MESSAGE _ SIZE _ BYTES , ĊĠĠĠ ĠConsumer Config . SESSION _ TIMEOUT _ MS _ CONFIG Ġto ĠSESSION _ TIMEOUT _ MS _ CONFIG Ċ ) ĊĊ Ċ fun Ġide mpot ent Producer Default Config () Ġ= Ġmutable Map Of ( ĊĠĠĠ ĠProducer Config . MAX _ REQUEST _ SIZE _ CONFIG Ġto ĠK AF KA _ MAX _ MESSAGE _ SIZE _ BYTES , ĊĠĠĠ Ġ/* ĠThis Ġsettings Ġguarantee Ġexactly Ġonce , Ġin Ġorder Ġdelivery Ġper Ġpartition Ġfor Ġtopics Ġwith Ġreplication - factor Ġ>= Ġ 2 , ĊĠĠĠĠĠĠ Ġand Ġassuming Ġthat Ġthe Ġsystem Ġdoesn 't Ġsuffer Ġmultiple Ġhard Ġfailures Ġor Ġconcurrent Ġtransient Ġfailures . ĊĠĠĠĠĠĠ Ġhttps :// bit . ly / 2 Ij n H xl Ġ*/ ĊĠĠĠ ĠProducer Config . ACK S _ CONFIG Ġto Ġ" all ", ĊĠĠĠ ĠProducer Config . MAX _ IN _ FL IGHT _ REQUEST S _ PER _ CONNECTION Ġto Ġ 2 , ĊĠĠĠ ĠProducer Config . RE TR IES _ CONFIG Ġto ĠInt . MAX _ VALUE , ĊĠĠĠ ĠProducer Config . ENABLE _ ID EMP OT ENCE _ CONFIG Ġto Ġtrue Ċ ) Ċ Ċ fun Ġdefault Producer Config () Ġ= Ġmutable Map Of ( ĊĠĠĠ ĠProducer Config . MAX _ REQUEST _ SIZE _ CONFIG Ġto ĠK AF KA _ MAX _ MESSAGE _ SIZE _ BYTES , ĊĠĠĠ ĠProducer Config . ACK S _ CONFIG Ġto Ġ" all " Ċ ) Ċ