commitsync（）实际上提交了什么？

Question

commitsync是像JavaDoc声称的那样提交了“在最后一次轮询（）上返回的偏移量”（这可能会遗漏一些没有包含在最后一次poll结果中的分区），还是实际上提交了所有订阅分区的最新位置？考虑到AllConsumed:https://github.com/apache/kafka/blob/2.4.0/clients/src/main/java/org/apache/kafka/clients/consumer/kafkaconsumer.java#l1387

@Override
public void commitSync(Duration timeout) {
    acquireAndEnsureOpen();
    try {
        maybeThrowInvalidGroupIdException();
        if (!coordinator.commitOffsetsSync(subscriptions.allConsumed(), time.timer(timeout))) {
            throw new TimeoutException("Timeout of " + timeout.toMillis() + "ms expired before successfully " +
                    "committing the current consumed offsets");
        }
    } finally {
        release();
    }
}

Answer 1

它只提交实际轮询和处理的偏移量。如果上次投票中没有包括某些抵消，则这些抵消将不会被提交。

它不会提交所有订阅分区的最新位置。这将干扰Kafka的消费者抵消管理概念，以便能够在应用程序中断的地方重新启动应用程序。

根据我的理解，AllConsulted等效于commitsync的注释也记录了上次轮询中包含的的所有偏移量