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