You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/12/11 20:32:46 UTC
kafka git commit: KAFKA-2981: Fix javadoc in KafkaConsumer
Repository: kafka
Updated Branches:
refs/heads/trunk 01f3e59ef -> fd8af25d0
KAFKA-2981: Fix javadoc in KafkaConsumer
https://issues.apache.org/jira/browse/KAFKA-2981
Author: Xin Wang <be...@163.com>
Reviewers: Guozhang Wang
Closes #668 from vesense/patch-2
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fd8af25d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fd8af25d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fd8af25d
Branch: refs/heads/trunk
Commit: fd8af25d0ae354e962850c9d6b5991056613aa2d
Parents: 01f3e59
Author: Xin Wang <be...@163.com>
Authored: Fri Dec 11 11:32:42 2015 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Fri Dec 11 11:32:42 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/fd8af25d/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 772e621..a7ec02b 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