KafkaConsumer的同步commit和异步commit。
KafkaConsumer这个类实现了同步commit和异步commit。同步commit的实现函数如下: public void commitSync(final Map<TopicPartition, OffsetAndMetadata> offsets, final Duration timeout) { acquireAndEnsureOpen();...