第 117 章 KafkaMirrorMakerConsumerSpec schema reference

使用 consumer.numStreams 属性配置消费者的流数量。

您可以通过增加消费者线程的数量来增加镜像主题的吞吐量。使用者线程属于为 Kafka MirrorMaker 指定的使用者组。主题分区分配在消费者线程中，它会并行使用消息。