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("bootstrap.servers", "localhost:9092"); * props.put("group.id", "test"); * props.put("enable.auto.commit", "false"); - * props.put("auto.commit.interval.ms", "1000"); * props.put("session.timeout.ms", "30000"); * props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); * props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
