[KAFKA-14745] MirrorSourceConnector keeps creating ReplicationPolicy instances

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.5.0
• Component/s: mirrormaker
• Assignee: Mickael Maison
• Reporter: Mickael Maison
• Created: 23/Feb/23 15:13
• Updated: 03/Mar/23 11:14
• Resolved: 03/Mar/23 11:14

Description

In MirrorSourceConnector.findTargetTopicPartitions() we call MirrorSourceConfig.checkpointsTopic() for each remote topic or all topics when using IdentityReplicationPolicy.

The issue is that checkpointsTopic() calls MirrorSourceConfig.replicationPolicy() which always creates a new instance of the ReplicationPolicy.

Issue Links

• links to: GitHub Pull Request #13328