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 <[email protected]> Reviewers: Guozhang Wang Closes #668 from vesense/patch-2 (cherry picked from commit fd8af25d0ae354e962850c9d6b5991056613aa2d) Signed-off-by: Guozhang Wang <[email protected]> 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 <[email protected]> Authored: Fri Dec 11 11:32:42 2015 -0800 Committer: Guozhang Wang <[email protected]> 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
