我正在阅读 Kafka：权威指南，并希望更好地了解重新平衡侦听器。简单书中的示例使用HashMap 来维护当前已处理的偏移量，并将在撤销分区时提交当前状态。我的担忧是：
我对代码示例有两个问题/疑问：
【问题讨论】：
我重新阅读了书中的部分，我同意我也有点困惑！
Javadoc 声明：
此回调将仅在用户线程中作为 每当分区分配发生变化时调用 poll(long)。
我查看了代码并确认重新平衡侦听器方法确实在拥有消费者的同一线程中调用。
是的，在重新平衡侦听器中提交时，您应该使用commitSync()。
为了解释原因，让我们看一下黄金路径示例。我们从消费者愉快地消费开始，并定期向协调器发送心跳。在某些时候，协调器会向心跳请求返回REBALANCE_IN_PROGRESS 错误。这可能是由想要加入组的新成员、成员离开或心跳失败或从订阅中添加/删除新分区引起的。此时，所有消费者都需要重新加入群组。
在尝试重新加入组之前，消费者将同步执行ConsumerRebalanceListener.onPartitionsRevoked()。监听器返回后，消费者将向协调器发送 JoinRequest 以重新加入组。
也就是说，我认为这就是您所考虑的，如果您的回调需要太长时间 (> session.timeout.ms) 才能提交，则该组可能已经在另一代中，并且具有偏移量的分区正在尝试提交分配给另一个成员。在这种情况下，即使是同步的，提交也会失败。但是通过在侦听器中使用commitSync()，可以保证消费者在完成提交之前不会重新加入组。
【讨论】：
commitSync 将导致代理拒绝它。那将是一个不可重试的事件，消费者可以按照您认为合适的方式处理它吗？