我使用kafka consumer api构建了一个consumer，这个consumer的工作方式应该是从主题中获取n条消息，并以并发方式处理它们，然后每个线程为它处理的消息提交偏移量。所以api中的poll（）调用取决于设置的时间，是否只有在所有线程都处理了前一批并提交了偏移量之后，我们才能对下一批进行poll（）呢？