KafkaConsumer的同步commit和异步commit。

KafkaConsumer这个类实现了同步commit和异步commit。 同步commit的实现函数以下: public void commitSync(final Map<TopicPartition, OffsetAndMetadata> offsets, final Duration timeout) { acquireAndEnsureOpen();
相关文章
相关标签/搜索