Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
None
-
None
Description
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.
Attachments
Issue Links
- is caused by
-
KAFKA-12468 Initial offsets are copied from source to target cluster
-
- Resolved
-
- links to