@半兽人
我这边碰到个问题想问下,
一个topic只有一个消费者组,流出流量是流入流量的两倍,lag没有积压,这是为什么?
副本数是2,流出流量是 副本数*2 ?
1、out *
副本数。而且你的消息会被不同的消费者订阅,而你的发送者只有一个。
2、你的集群物理的网络和节点内存,决定了你的上限。
3、是的
group.id=mirrormaker
是消费者组,这kafka的基础,MirrorMaker的底层功能,也是作为消费者组,将数据传输到B的。
你每次启动它的时候,换个消费者组名字就不会发了。
我想不到其他的办法了(因为本身同一时刻,只有一个kafka集群提供服务)。
A为什么还要记录group.id=mirrormaker呢?发现新的10000条消息是我B->A的吧 起A的时候然后它认为新增了10000条然后又同步过去了是这样么? 我该如何解决呢