Greg Harris created KAFKA-14797: ----------------------------------- Summary: 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
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)