You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Greg Harris (Jira)" <ji...@apache.org> on 2023/03/08 23:06:00 UTC
[jira] [Created] (KAFKA-14797) MM2 does not emit offset syncs when conservative translation logic exceeds positive max.offset.lag
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)