原kafka集群是有0.8.2.2和0.10.2.2两个版本的,目标集群是kafka 2.3.1版本的,可以使用kafka mirrorMaker进行集群间的数据同步吗
可以的。
https://stackoverrun.com/cn/q/10437077 这是我在网上看到别人说的不可以。我是这样理解的,kafka mirrorMaker不是消费者和生产者的组成的嘛,消费者要与原集群的版本号一致,生产者要与目标集群的kafka版本一致。但是组成mirrorMaker的消费者和生产者版本就不一致了,这样不是会有问题的吗?那怎么操作才可以实现跨版本的集群数据同步呢
https://www.orchome.com/34你从0.8里面读取消息,然后发到新的kafka版本上,注意这2个步骤。是不是跟kafka什么版本没关系,你自己写个java程序去做这件事,也不会关心kafka版本(客户端版本不算)。
就是说直接使用mirrorMaker还是不行的,需要对mirrorMaker进行再开发了
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
可以的。
https://stackoverrun.com/cn/q/10437077 这是我在网上看到别人说的不可以。
我是这样理解的,kafka mirrorMaker不是消费者和生产者的组成的嘛,消费者要与原集群的版本号一致,生产者要与目标集群的kafka版本一致。但是组成mirrorMaker的消费者和生产者版本就不一致了,这样不是会有问题的吗?
那怎么操作才可以实现跨版本的集群数据同步呢
https://www.orchome.com/34
你从0.8里面读取消息,然后发到新的kafka版本上,注意这2个步骤。
是不是跟kafka什么版本没关系,你自己写个java程序去做这件事,也不会关心kafka版本(客户端版本不算)。
就是说直接使用mirrorMaker还是不行的,需要对mirrorMaker进行再开发了
你的答案