apache-kafka - 限速卡夫卡镜像

Question

是否有任何选项可以限制/速率限制MirrorMaker进程，以便目标集群始终以可预测的方式落后于源集群？

此选项是否--num.streams有助于限制流量？

我必须限制并保持目标集群上的延迟，因此它使消费者能够轻松切换到目标集群，而不会丢失任何要处理的消息。

我的消费者可以处理消息中的重复项。但我也不希望他们从一开始/最早消费消息。

卡夫卡版本是：0.9

标签： apache-kafkaapache-kafka-mirrormaker