ApacheKafkaConnectMirrorMaker2未实现双向复制
创始人
2024-09-06 03:30:38
0

MirrorMaker2在默认情况下是单向复制,如果要实现双向复制,需要进行一些配置。具体步骤如下:

  1. 确保源和目标Kafka集群都已经安装了MirrorMaker2。

  2. 创建一个新的Kafka连接器,例如:

bin/connect-standalone.sh config/connect-standalone.properties config/connect-mirror-maker2.properties
  1. 在"connect-mirror-maker2.properties"文件中,将属性"config.sync.topic.acl.enabled"设置为"true"。这将启用权限检查,以确保MirrorMaker2在源和目标集群之间同步主题时不会遇到权限问题。

  2. 在源和目标Kafka集群的配置文件中,启用"inter.broker.protocol.version"属性。这将确保源和目标集群之间的协议版本相同,从而消除任何潜在的兼容性问题。

  3. 在目标Kafka集群上,创建一个新的主题,并使用复制因子将其关联到源主题。例如:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mirrored-topic

然后,使用以下命令将目标主题关联到源主题:

bin/kafka-configs.sh --zookeeper localhost:2181 --alter --add-config 'mirror.source.cluster.connect'='localhost:9092' --entity-type topics --entity-name mirrored-topic
  1. 在新的Kafka连接器中,将"config.sync.topic.enable"属性设置为"true"。这将启用主题同步。

  2. 运行以下命令:

bin/connect-standalone.sh config/connect-standalone.properties config/connect-mirror-maker2.properties

现在,您的MirrorMaker2已经配置为进行双向复制。请注意,这些步骤仅包括最基本的设置。您可能需要根据自己的需要进行更多配置。

相关内容

热门资讯

玩家必知教程!闲逸亲友圈app... 玩家必知教程!闲逸亲友圈app辅助,九哥玩辅助软件安装(竟然真的有挂)1、九哥玩辅助软件安装公共底牌...
一分钟了解!手机游戏辅助脚本工... 一分钟了解!手机游戏辅助脚本工具,天天微友助手破解版(都是真的有挂)1、一分钟了解!手机游戏辅助脚本...
推荐十款!老k麻将辅助器,辅助... 推荐十款!老k麻将辅助器,辅助定制交易平台(本来是真的有挂)1、下载好辅助定制交易平台正确养号方法之...
总算了解!大唐辅助软件,财神十... 总算了解!大唐辅助软件,财神十三张脚本辅助(一贯真的有挂)1)财神十三张脚本辅助辅助插件:进一步探索...
专业讨论!纳祥游戏脚本,微信小... 专业讨论!纳祥游戏脚本,微信小程序辅助工具(确实是真的有挂)1、在微信小程序辅助工具插件功能辅助器技...
指导大家!微乐麻将脚本掌上程序... 指导大家!微乐麻将脚本掌上程序,琼崖海南麻将辅助器(确实存在有挂)1、下载好微乐麻将脚本掌上程序正确...
分享实测!牛总管辅助免费版,和... 分享实测!牛总管辅助免费版,和和营口辅助(一贯是有挂)1)牛总管辅助免费版免费钻石:进一步探索牛总管...
推荐一款!乐乐围棋入门辅助,小... 推荐一款!乐乐围棋入门辅助,小程序微乐辅助器2.0(竟然有挂)该软件可以轻松地帮助玩家将小程序微乐辅...
信息共享!丽水茶苑手机辅助,四... 信息共享!丽水茶苑手机辅助,四川途游辅助软件瞎子啊(确实是真的有挂)1、起透看视 四川途游辅助软件瞎...
我来教教大家!天道辅助器使用教... 我来教教大家!天道辅助器使用教程,微乐陕西小程序破解器下载(竟然有挂)1、玩家可以在微乐陕西小程序破...