Re: Mirror Maker 2.0 NOT generating checkpoints for consumers running in assign mode

I am still facing the same issue. On Fri, Sep 11, 2020, 4:46 PM wrote: > Hi Ananya > Are you able to resolve this issue ,I'm also facing same issue . > > What parameter should be pass here if I'm doing failover from cluster A > ---> B > > Map newOffsets = > RemoteClusterUtils.transla

Re: Mirror Maker 2.0 NOT generating checkpoints for consumers running in assign mode

Hi Ananya Are you able to resolve this issue ,I'm also facing same issue . What parameter should be pass here if I'm doing failover from cluster A ---> B Map newOffsets = RemoteClusterUtils.translateOffsets(properties, "A", "TestTopic-123", Duration.ofMillis(5500)); Properties= Bo

Mirror Maker 2.0 NOT generating checkpoints for consumers running in assign mode

Hello All, I was using a mirror maker 2.0. I was testing the consumer checkpointing functionality. I found that the RemoteClusterUtils.translateOffsets do not give checkpoints for the consumer which run in assign mode. I am using mirror maker 2.0 of Kafka Version 2.5.0 and Scala version 2.12 My