kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2981: Fix javadoc in KafkaConsumer
Date Fri, 11 Dec 2015 19:32:52 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.9.0 ba09aef53 -> 8071f105f


KAFKA-2981: Fix javadoc in KafkaConsumer

https://issues.apache.org/jira/browse/KAFKA-2981

Author: Xin Wang <best.wangxin@163.com>

Reviewers: Guozhang Wang

Closes #668 from vesense/patch-2

(cherry picked from commit fd8af25d0ae354e962850c9d6b5991056613aa2d)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


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

Branch: refs/heads/0.9.0
Commit: 8071f105f63e356d0cc20150cbbe0dc8f3f6b1b0
Parents: ba09aef
Author: Xin Wang <best.wangxin@163.com>
Authored: Fri Dec 11 11:32:42 2015 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Dec 11 11:32:49 2015 -0800

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/8071f105/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 70a3ae6..a0995f3 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
@@ -355,7 +355,7 @@ import java.util.regex.Pattern;
  *
  *     public void run() {
  *         try {
- *             consumer.subscribe("topic");
+ *             consumer.subscribe(Arrays.asList("topic"));
  *             while (!closed.get()) {
  *                 ConsumerRecords records = consumer.poll(10000);
  *                 // Handle new records


Mime
View raw message