package Ġio . github . cf st out . k aco on . kafka . consumer . config Ċ Ċ import Ġcom . fasterxml . jackson . annotation . JsonProperty Ċ import Ġio . github . cf st out . k aco on . kafka . types . Consumer GroupName Ċ import Ġjava . time . Duration Ċ import Ġjava . util . regex . Pattern Ċ Ċ data Ġclass ĠConsumer Group Config Ċ @ Jvm Over loads Ċ constructor (@ JsonProperty (" groupName ") Ġval ĠgroupName : ĠConsumer GroupName , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ JsonProperty (" pattern ") Ġprivate Ġval Ġpattern String : ĠString , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ JsonProperty (" consumer Override Config ") Ġval Ġoverrides : ĠMap < String , ĠAny > Ġ= Ġmap Of (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ JsonProperty (" commit Offsets ") Ġval Ġcommit Offsets : ĠDuration Ġ= ĠDuration . of Seconds ( 5 ), Ġ// Ġhow Ġoften Ġto Ġcommit Ġoffsets ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ JsonProperty (" consumer Flow Config ") Ġval Ġconsumer Flow Config : ĠConsumer Flow Config Ġ= ĠConsumer Flow Config (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ JsonProperty (" consumer Poll Timeout ") Ġval Ġpoll Timeout : ĠDuration Ġ= ĠDuration . of Millis ( 1 0 ) Ġ// Ġtimeout Ġwe Ġpass Ġto Ġconsumer . poll () Ċ ) Ġ{ ĊĠĠĠ Ġval Ġpattern : ĠPattern ĊĠĠĠĠĠĠĠ Ġget () Ġ= ĠPattern . compile ( pattern String ) Ċ }