I've a massive amount of lag when i try to consume MM2 replicated topics

Hey guys, i’ve 2 cluster one is production the other is disaster recovery, i replicate the topics from Prod to DR with same name but when i start to consume DR topics, the consumer doesn’t start from the end but instead, starts from the beginning. How can i make the consumers start from the end.

Hi @jumpsrange

welcome to the forum :slight_smile:

You need to enable this feature:

https://cwiki.apache.org/confluence/display/KAFKA/KIP-545%3A+support+automated+consumer+offset+sync+across+clusters+in+MM+2.0

hth,
michael

1 Like

Thanks for the help, I did add that property to my config file but still didn’t fix the issue.

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.