You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jj...@apache.org on 2015/05/21 23:33:06 UTC
kafka git commit: Revert "KAFKA-2186;
Follow-up to KAFKA-1650 - add selective offset commit to"
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 <jj...@gmail.com>
Authored: Thu May 21 14:32:58 2015 -0700
Committer: Joel Koshy <jj...@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();