Tomasz Gański created KAFKA-4760: ------------------------------------ Summary: Restarting one MirrorMaker causes a global pause in mirroring. Key: KAFKA-4760 URL: https://issues.apache.org/jira/browse/KAFKA-4760 Project: Kafka Issue Type: Improvement Reporter: Tomasz Gański Attachments: 1_mm_stop.png
When 1 MirrorMaker is restarted in consumer group, the whole consumer group stop working and lead to big consumer lag. !1_mm_stop.png|thumbnail! It becoming huge problem when you want keep system stable and guarantee that crucial messages come as soon as possible. In this case each deployment or setting change is risky. It would be grate if MirrorMaker could rejoin to previous assigned partitions and not caused consumer group rebalance. The rejoins to existing consumer group is based on *memberId* and *group generation id*. I would nice if it would be possible to make them persistence and keep this variable during MirrorMaker restart. -- This message was sent by Atlassian JIRA (v6.3.15#6346)