From 59319033fd29b5ba0e54ca64b4a6f7412ec8ee5e Mon Sep 17 00:00:00 2001 From: jqin Date: Thu, 21 May 2015 15:04:06 -0700 Subject: [PATCH] rebased on trunk --- .../main/scala/kafka/javaapi/consumer/ConsumerConnector.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java b/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java index cc3400f..ca74ca8 100644 --- a/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java +++ b/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java @@ -20,6 +20,9 @@ package kafka.javaapi.consumer; import java.util.List; import java.util.Map; + +import kafka.common.OffsetAndMetadata; +import kafka.common.TopicAndPartition; import kafka.consumer.KafkaStream; import kafka.consumer.TopicFilter; import kafka.serializer.Decoder; @@ -65,6 +68,14 @@ public interface ConsumerConnector { public void commitOffsets(boolean retryOnFailure); /** + * Commit offsets using the provided offsets map + * + * @param offsetsToCommit a map containing the offset to commit for each partition. + * @param retryOnFailure enable retries on the offset commit if it fails. + */ + public void commitOffsets(Map offsetsToCommit, boolean retryOnFailure); + + /** * Shut down the connector */ public void shutdown(); -- 1.8.3.4 (Apple Git-47)