kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: remove "auto.commit.interval.ms" from "Manual Offset Control" example
Date Sat, 02 Jul 2016 01:08:58 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 2098529b4 -> 32e24b7c2


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

Author: xuwei-k <6b656e6a69@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

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 <6b656e6a69@gmail.com>
Authored: Sat Jul 2 02:09:01 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
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;);


Mime
View raw message