Skip to content

Commit

Permalink
Revert "KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset co…
Browse files Browse the repository at this point in the history
…mmit to"

This reverts commit 23ff851.
  • Loading branch information
jjkoshy committed May 21, 2015
1 parent 23ff851 commit 467736c
Showing 1 changed file with 0 additions and 11 deletions.
11 changes: 0 additions & 11 deletions core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
Original file line number Diff line number Diff line change
Expand Up @@ -20,12 +20,9 @@

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 {
/**
Expand Down Expand Up @@ -67,14 +64,6 @@ public interface ConsumerConnector {
public void commitOffsets();
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
*/
Expand Down

0 comments on commit 467736c

Please sign in to comment.