我在虚拟机上部署了两个单节点的kafka2.4.0,打算测一下MirrorMaker2.0
同步消费偏移量的问题,启动命令是:
./kafka-mirror-maker.sh --consumer.config consumer.config --producer.config producer.config --whitelist ".*"
执行后,往源kafka的指定topic发送数据并消费, 如下:
源kafka消费也正常
但当我端开源kafka的消费, 启动目标kafka的消费命令时发现并没有按照源kafka消费端的偏移量来消费, 而是重新开始消费:
想请问下这是不是说我使用的还是MirrorMaker1.0
版本, 并没有真正的启用2.0版本?那么真正配置 MirrorMaker2.0 的流程是什么? 麻烦大佬给看看
你好,想问一下您这个问题怎么解决的呀,我使用的2.4.1的版本,也不能同步消费者组
是的,
kafka 2.4
还不支持2.0
,所以你的还是1.0
版本。解决,升级kafka版本
kafka 2.6+
后是支持的。可参考:https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0
谢谢大佬 我根据这个链接重新下载了2.70版本 也把参数重新配置了 但还是不行 执行起来倒是没报错 但数据也没过去 咱站里有相关的资料或案例么 我看看是不是我参数配置的有问题
这个问题解决了 大佬给的这个网站其实不能实际配置mirror maker2.0 有部分参数没有写进去 导致配置不行
赞,我会尽快完善这块资料。
你的答案