kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject kafka git commit: Revert "KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to"
Date Thu, 21 May 2015 21:33:06 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 23ff851f3 -> 467736c7a


Revert "KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to"

This reverts commit 23ff851f30bb55e794aefd2fae5367845d9230ee.


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/467736c7
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/467736c7
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/467736c7

Branch: refs/heads/trunk
Commit: 467736c7ad4a24e2eb1048b6fe4211bec02e4a05
Parents: 23ff851
Author: Joel Koshy <jjkoshy@gmail.com>
Authored: Thu May 21 14:32:58 2015 -0700
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Thu May 21 14:32:58 2015 -0700

----------------------------------------------------------------------
 .../scala/kafka/javaapi/consumer/ConsumerConnector.java  | 11 -----------
 1 file changed, 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/467736c7/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java b/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
index f340065..cc3400f 100644
--- a/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
+++ b/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
@@ -20,12 +20,9 @@ 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 {
   /**
@@ -68,14 +65,6 @@ 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<TopicPartition, OffsetAndMetadata> offsetsToCommit,
boolean retryOnFailure);
-
-  /**
    *  Shut down the connector
    */
   public void shutdown();


Mime
View raw message