kafka使用者应用程序具有严重的延迟（在高峰时间消耗kafka事件的速度不够快）。kafka主题有120个分区，使用者组总共有30个主机，每个主机有两个使用者，因此每个使用者使用2个kafka分区。我们使用的主机是32核的awsc5.9xlarge示例。每个使用者被放入一个java.lang.thread中，在每个线程中，一个线程池由250个线程创建。
我们已经验证了cpu/memory/io都不是瓶颈。然后我们把250名工人增加到500名，但他们留下来了。然后我们又改回了250个工人，但是从每台主机2个消费者增加到了4个。因此，每个消费者从一个kafka分区进行消费。现在问题解决了，延迟降到很低。
我的问题是，为什么线程池中从250个增加到500个没有帮助，但是每个主机中从2个消费者增加到4个消费者却有帮助？

private class ConsumerThread extends Thread {
    public ConsumerThread(StremProcessor processor) {
      this.processor = processor;
      this.consumer = new KafkaConsumer()
    }
    @Override
    public void run() {
        ExecutorService executor = Executors.newFixedThreadPool(250);
        while (true) {
          Data data = consumer.poll()
          executor.invokeAll(getTasks(data, processor)); //processor is 
        }    
    }
}