1

我已经启动了 kafka MirrorMaker 来跨数据中心镜像数据。MirrorMaker 运行配置中有一个选项--num.streams来决定使用者线程的数量。据我所知,--num.producersKafka 0.9 已弃用,默认情况下有一个生产者线程来处理消费流。这是正确的吗?如果--num.streams它很高,它不会只用一个生产者线程造成瓶颈吗?

如果这是预期的行为,是否最好启动“N”个 MirrorMaker 进程,--num.streams=1以便有 1:1 的消费者和生产者线程,而不是一个 MM 进程,--num.streams="N"以提高 MirrorMaker 性能并防止滞后?

4

0 回答 0