[ 
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)

Reply via email to