KafkaConsumer的同步commit和異步commit。

KafkaConsumer這個類實現了同步commit和異步commit。 同步commit的實現函數以下: public void commitSync(final Map<TopicPartition, OffsetAndMetadata> offsets, final Duration timeout) { acquireAndEnsureOpen();
相關文章
相關標籤/搜索