KafkaConsumer#pause是否会影响当前对投票的调用？

Question

如果我设置了我自己的重新平衡侦听器，并且在onPartitionsAssigned内部调用consumer.pause(partitions)，那么当前对poll的调用(从其中调用该重新平衡侦听器)会返回任何记录吗？

在医生那里，我会为自己找到这个答案吗？

编辑：

我在文件里看到了这个-

挂起从请求的分区获取。将来对轮询(Long)的调用将不会从这些分区返回任何记录，直到使用简历(Collection)恢复这些记录为止。请注意，此方法不影响分区订阅。特别是，当使用自动分配时，它不会导致组重新平衡。

但是，我觉得这并不能明确地说明对poll的调用是否会返回poll内部调用的重平衡回调中暂停的分区的数据。

Answer 1

我不确定我能不能回答你的问题。但是从规范上看，它是干净的，pause()会影响未来的调用投票。

挂起从请求的分区获取。将来对轮询(Long)的调用将不会从这些分区返回任何记录，直到使用简历(Collection)恢复这些记录为止。请注意，此方法不影响分区订阅。特别是，当使用自动分配时，它不会导致组重新平衡。

https://kafka.apache.org/0102/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)