是否有任何选项来限制mirrormaker进程,以便目标集群总是以可预测的方式落后于源集群?这个选项有用吗 --num.streams 帮助节流?我必须限制并保持目标集群上的延迟,这样消费者就可以轻松地切换到目标集群,而不会丢失任何要处理的消息。我的消费者可以处理消息中的重复项。但我也不希望他们从一开始就/最早地消费信息。Kafka版本是:0.9
--num.streams
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!