package Ġkafka . flow . consumer Ċ Ċ import Ġjava . time . Duration Ċ import Ġjava . time . Instant Ċ Ċ public Ġsealed Ġinterface ĠAuto Stop Policy Ġ{ ĊĠĠĠ Ġpublic Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġpublic Ġfun Ġnever (): ĠNever Ġ= ĠNever ĊĠĠĠĠĠĠĠ Ġpublic Ġfun Ġwhen Up ToDate (): ĠWhen Up ToDate Ġ= ĠWhen Up ToDate ĊĠĠĠĠĠĠĠ Ġpublic Ġfun Ġat Specific Time ( stop Time : ĠInstant ): ĠAt Specific Time Ġ= ĠAt Specific Time ( stop Time ) ĊĠĠĠĠĠĠĠ Ġpublic Ġfun Ġspecific Offset From Now ( duration : ĠDuration ): ĠSpecific Offset From Now Ġ= ĠSpecific Offset From Now ( duration ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġpublic Ġobject ĠNever Ġ: ĠAuto Stop Policy ĊĠĠĠ Ġpublic Ġobject ĠWhen Up ToDate Ġ: ĠAuto Stop Policy ĊĠĠĠ Ġpublic Ġdata Ġclass ĠAt Specific Time ( public Ġval Ġstop Time : ĠInstant ) Ġ: ĠAuto Stop Policy ĊĠĠĠ Ġpublic Ġdata Ġclass ĠSpecific Offset From Now ( public Ġval Ġduration : ĠDuration ): ĠAuto Stop Policy Ċ } ĊĊĊĊ