Spring-Kafka：在使用用户暂停/恢复时发生再平衡，这不应该根据文档

Question

Spring-Kafka：当按照文档使用Pause/Resume方法暂停/恢复消费者时，当使用自动分配时不应该发生再平衡，但它不工作，再平衡发生了。如何暂停/恢复消费者并在一段时间后保持轮询而不重新平衡？

用例：消费者应该暂停一段时间，并保持轮询给心跳，并在时间结束后恢复，但Kafka不应该在消费者暂停时重新平衡。

            System.out.println("Consumer[" + Thread.currentThread().getName() + "] Partition [" + topicPartition + "] stopped consumption.");
            consumer.pause(Collections.singleton(topicPartition));                    
            try {
                    Thread.sleep(60000);
                    consumer.resume(Collections.singleton(topicPartition));
                    System.out.println("Consumer[" + Thread.currentThread().getName() + "] Partition [" + topicPartition + "] resumed consumption.");
            } catch (InterruptedException e) {              
                       e.printStackTrace();
            }

日志：2019-02-19 15:19:49.173信息82272---[rTaskExecutor-1]O.A.K.C.C.Internals.Abstract协调器:[消费者客户=Consumer-2,GroupID=Customer]（重新）加入组2019-02-19 15:19:49.175信息82272---[rTaskExecutor-2]O.A.K.C.Internals.Abstract协调器:[rTaskExecutor-2]O.A.K.C.Internals.Abstract协调器:[消费者客户=Consumer-3,GroupID=Customer]（重新）加入组2019-02-19 entid=consumer-4,groupid=customer]（重新）加入组

2019-02-19 15:19:49.192信息82272---[rTaskExecutor-1]O.A.K.C.C.Internals.Abstract协调器:[消费者客户=Consumer-2,GroupID=Customer]成功加入第581代组201 9-02-19 15:19:49.192信息82272---[rTaskExecutor-2]O.A.K.C.Internals.Abstract协调器:[消费者客户=Consumer-3,GroupID=Customer]成功加入第581代组

Answer 1

阅读Kafka文档。

暂停使用者只是意味着，在调用resume()之前，后续的poll()将不会返回任何记录，但是为了防止重新平衡，您仍然必须在max.poll.interval.ms中调用poll()。