kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject kafka git commit: kafka-2033; Small typo in documentation; patched by Pierre-Yves Ritschard; reviewed by Jun Rao
Date Tue, 07 Apr 2015 21:40:11 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 04fce48e1 -> b1cc72510


kafka-2033; Small typo in documentation; patched by Pierre-Yves Ritschard; reviewed by Jun
Rao


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

Branch: refs/heads/trunk
Commit: b1cc72510792fdf83ac2d6f302ea07c7ea397ce4
Parents: 04fce48
Author: Pierre-Yves Ritschard <pyr@spootnik.org>
Authored: Tue Apr 7 14:40:06 2015 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Tue Apr 7 14:40:06 2015 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/clients/consumer/KafkaConsumer.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/b1cc7251/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 862f1f8..2124334 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
@@ -119,7 +119,7 @@ import org.slf4j.LoggerFactory;
  * 
  * <pre>
  *     Properties props = new Properties();
- *     props.put(&quot;metadata.broker.list&quot;, &quot;localhost:9092&quot;);
+ *     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;true&quot;);
  *     props.put(&quot;auto.commit.interval.ms&quot;, &quot;1000&quot;);
@@ -139,7 +139,7 @@ import org.slf4j.LoggerFactory;
  * the config <code>auto.commit.interval.ms</code>.
  * <p>
  * The connection to the cluster is bootstrapped by specifying a list of one or more brokers
to contact using the
- * configuration <code>metadata.broker.list</code>. This list is just used to
discover the rest of the brokers in the
+ * configuration <code>bootstrap.servers</code>. This list is just used to discover
the rest of the brokers in the
  * cluster and need not be an exhaustive list of servers in the cluster (though you may want
to specify more than one in
  * case there are servers down when the client is connecting).
  * <p>
@@ -171,7 +171,7 @@ import org.slf4j.LoggerFactory;
  * 
  * <pre>
  *     Properties props = new Properties();
- *     props.put(&quot;metadata.broker.list&quot;, &quot;localhost:9092&quot;);
+ *     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;);


Mime
View raw message