我们有5个Kafka代理,复制因子3,和2个主题-t1和t2。t1主题有100个分区,t2有6个分区。当使用kafka生产者(使用kafkaproducer.send())向t1和t2写入时,生产者.send()所需的时间约为1秒。但是将t2中的分区数从6增加到100后,send()的总时间增加到20秒。知道为什么吗?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!