Repository: kafka
Updated Branches:
  refs/heads/trunk 2098529b4 -> 32e24b7c2


MINOR: remove "auto.commit.interval.ms" from "Manual Offset Control" example

Author: xuwei-k <[email protected]>

Reviewers: Ismael Juma <[email protected]>

Closes #1578 from xuwei-k/Manual-Offset-Control-example


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

Branch: refs/heads/trunk
Commit: 32e24b7c28e357c051bbe21b08c4e8c6d45a3907
Parents: 2098529
Author: Kenji Yoshida <[email protected]>
Authored: Sat Jul 2 02:09:01 2016 +0100
Committer: Ismael Juma <[email protected]>
Committed: Sat Jul 2 02:09:01 2016 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java  | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/32e24b7c/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
----------------------------------------------------------------------
diff --git 
a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java 
b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
index 04b41ba..251db1c 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
@@ -242,7 +242,6 @@ import java.util.regex.Pattern;
  *     props.put(&quot;bootstrap.servers&quot;, &quot;localhost:9092&quot;);
  *     props.put(&quot;group.id&quot;, &quot;test&quot;);
  *     props.put(&quot;enable.auto.commit&quot;, &quot;false&quot;);
- *     props.put(&quot;auto.commit.interval.ms&quot;, &quot;1000&quot;);
  *     props.put(&quot;session.timeout.ms&quot;, &quot;30000&quot;);
  *     props.put(&quot;key.deserializer&quot;, 
&quot;org.apache.kafka.common.serialization.StringDeserializer&quot;);
  *     props.put(&quot;value.deserializer&quot;, 
&quot;org.apache.kafka.common.serialization.StringDeserializer&quot;);

Reply via email to