From db5fda3f393f6b869e5c7809ecf02c7bb0329d5d Mon Sep 17 00:00:00 2001 From: jqin Date: Mon, 11 May 2015 18:38:55 -0700 Subject: [PATCH] Patch for KAFKA-2186 follow-up patch of KAFKA-1650, add the missing offset commit with map in java api --- core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java | 8 ++++++++ 1 file changed, 8 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..4446b53 100644 --- a/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java +++ b/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java @@ -20,9 +20,12 @@ package kafka.javaapi.consumer; import java.util.List; import java.util.Map; + +import kafka.common.OffsetAndMetadata; import kafka.consumer.KafkaStream; import kafka.consumer.TopicFilter; import kafka.serializer.Decoder; +import org.apache.kafka.common.TopicPartition; public interface ConsumerConnector { /** @@ -65,6 +68,11 @@ public interface ConsumerConnector { public void commitOffsets(boolean retryOnFailure); /** + * Commit offsets using a provided offsets map + */ + public void commitOffsets(Map offsetsToCommit, boolean retryOnFailure); + + /** * Shut down the connector */ public void shutdown(); -- 1.8.3.4 (Apple Git-47)