2.3. MirrorMaker 2.0 主题重命名更新
MirrorMaker 2.0 架构通过自动重命名远程主题来代表源集群来支持双向复制。原始集群的名称前面是主题名称的前面。
现在,您可以通过在源连接器配置中添加 IdentityReplicationPolicy 来覆盖自动重命名。应用此配置后,主题会保留其原始名称。
replication.policy.class= io.strimzi.kafka.connect.mirror.IdentityReplicationPolicy
- 1
- 添加可覆盖远程主题自动重命名的策略。该主题不会用源集群的名称来附加名称,而是保留其原始名称。
例如,覆盖在您要备份或将数据迁移到另一个集群的 主动/被动 集群配置中非常有用。在这两种情况下,您可能不希望自动重命名远程主题。