[ https://issues.apache.org/jira/browse/KAFKA-14797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chris Egerton resolved KAFKA-14797. ----------------------------------- Resolution: Fixed > MM2 does not emit offset syncs when conservative translation logic exceeds > positive max.offset.lag > -------------------------------------------------------------------------------------------------- > > Key: KAFKA-14797 > URL: https://issues.apache.org/jira/browse/KAFKA-14797 > Project: Kafka > Issue Type: Bug > Components: mirrormaker > Reporter: Greg Harris > Assignee: Greg Harris > Priority: Blocker > Fix For: 3.5.0, 3.4.1, 3.3.3 > > > This is a regression in MirrorMaker 2 introduced by KAFKA-12468. > Reproduction steps: > 1. Set max.offset.lag to a non-zero value. > 2. Set up a 1-1 replication flow which does not skip upstream offsets or have > a concurrent producer to the target topic. > 3. Produce more than max.offset.lag records to the source topic and allow > replication to proceed. > 4. Examine end offsets, checkpoints and/or target consumer group lag > Expected behavior: > Consumer group lag should be at most max.offset.lag. > Actual behavior: > Consumer group lag is significantly larger than max.offset.lag. -- This message was sent by Atlassian Jira (v8.20.10#820010)