Re: question about mm2 on consumer group offset mirroring

Hey Calvin, the property you're looking for is
emit.checkpoint.interval.seconds. That's how often MM will write
checkpoints, which includes consumer group offsets.

Ryanne

On Thu, Sep 30, 2021, 9:18 AM Calvin Chen <pingc.sh@hotmail.com> wrote:

> Hi all
>
> I have a question about the mirror make 2, on the consumer group offset
> mirroring, what is the duration for mm2 to detect consumer group offset
> change and mirror it to remote kafka consumer group?
>
> I have my mm2 code define as below:
>
>
> {{ kafka01_name }}->{{ kafka02_name }}.sync.group.offsets.enabled = true
> {{ kafka02_name }}->{{ kafka01_name }}.sync.group.offsets.enabled = true
>
> refresh.topics.interval.seconds=10
> refresh.groups.interval.seconds=10
>
> so I would expect the consumer group offset mirroring would happen every
> around 10 second, but during test, I see sometime consumer group offset
> mirroring are quick, sometimes it takes minutes, so I would like to know
> how is offset mirrored and why there is time difference, thanks
>
> -Calvin
>