[KAFKA-14095] Improve handling of sync offset failures in MirrorMaker

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.4.0
• Component/s: mirrormaker
• Assignee: Mickael Maison
• Reporter: Mickael Maison
• Reviewer: Chris Egerton
• Created: 21/Jul/22 17:08
• Updated: 23/Aug/22 14:25
• Resolved: 01/Aug/22 11:00

Description

MirrorMaker can automatically sync offsets when sync.group.offsets.enabled is set to true. However that only works if the consumer groups are not used in the target cluster otherwise committing offsets fails with UNKNOWN_MEMBER_ID.

Currently we treat this case as an error in the admin client so it emits an ERROR level log line. This is misleading as it's not an unexpected error and we should treat it the same way as other group level error codes.

In addition we should check the result of the alterConsumerGroupOffsets call in MirrorMaker and provide an helpful message in case of UNKNOWN_MEMBER_ID errors.

Issue Links

• links to: GitHub Pull Request #12432