You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Kafka 2.13.3.0.0环境下,如何禁用MM2自动创建复制主题?

可以禁用MM2的自动主题创建功能,且不影响核心同步特性

针对Kafka MirrorMaker2(2.13.3.0.0版本),完全可以禁用从源到目标集群的自动主题创建,同时保留记录同步、偏移量同步等核心功能,仅通过手动方式管理复制主题。具体配置方法如下:

核心配置修改

在MM2的配置文件(通常命名为mm2.properties)中添加或修改以下参数:

  • 全局禁用自动主题创建:
    auto.create.topics.enable=false
    
  • 如果需要针对特定同步任务单独配置(而非全局生效),可以在对应的连接器配置段中添加该参数,例如针对MirrorSourceConnector:
    source.cluster1.connector.auto.create.topics.enable=false
    

手动创建复制主题的注意事项

  1. 主题命名规则:需遵循MM2的复制策略,默认情况下目标主题名称格式为{源集群别名}.{源主题名}(比如源集群别名为cluster1,源主题为test-topic,则目标主题需命名为cluster1.test-topic)。如果自定义了replication.policy.separator参数,需对应调整命名。
  2. 主题参数对齐:手动创建目标主题时,需保证分区数、副本数、配置参数(如cleanup.policy、retention.ms等)与源主题一致,否则可能导致同步异常或性能问题。
  3. 偏移量同步验证:主题创建完成后,MM2会自动识别并开始同步该主题的记录和偏移量,无需额外配置。

额外建议

若要彻底杜绝目标集群的自动主题创建行为,可同时在目标集群的server.properties中设置:

auto.create.topics.enable=false

这一步可以防止其他客户端(非MM2)意外创建主题,进一步强化手动管理的规则。

内容的提问来源于stack exchange,提问作者krishna k maurya

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.16 10:30:53