From commits-return-10908-apmail-kafka-commits-archive=kafka.apache.org@kafka.apache.org Thu Dec 20 16:55:59 2018 Return-Path: X-Original-To: apmail-kafka-commits-archive@www.apache.org Delivered-To: apmail-kafka-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 6A2A918643 for ; Thu, 20 Dec 2018 16:55:59 +0000 (UTC) Received: (qmail 60827 invoked by uid 500); 20 Dec 2018 16:55:57 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 60756 invoked by uid 500); 20 Dec 2018 16:55:57 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 60634 invoked by uid 99); 20 Dec 2018 16:55:57 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Dec 2018 16:55:57 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 36B1C80589; Thu, 20 Dec 2018 16:55:57 +0000 (UTC) Date: Thu, 20 Dec 2018 16:55:56 +0000 To: "commits@kafka.apache.org" Subject: [kafka] branch trunk updated: KAFKA-7762; Update KafkaConsumer Javadoc examples to use poll(Duration timeout) API MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <154532495511.6253.5328969170385218103@gitbox.apache.org> From: manikumar@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: kafka X-Git-Refname: refs/heads/trunk X-Git-Reftype: branch X-Git-Oldrev: b23bf41e84d468185aa4165bf171b24735b8fecd X-Git-Newrev: d413117769efea0d5212ce29445049918209fd03 X-Git-Rev: d413117769efea0d5212ce29445049918209fd03 X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. manikumar pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new d413117 KAFKA-7762; Update KafkaConsumer Javadoc examples to use poll(Duration timeout) API d413117 is described below commit d413117769efea0d5212ce29445049918209fd03 Author: Matthias Wessendorf AuthorDate: Thu Dec 20 22:25:25 2018 +0530 KAFKA-7762; Update KafkaConsumer Javadoc examples to use poll(Duration timeout) API Author: Matthias Wessendorf Reviewers: Manikumar Reddy Closes #6052 from matzew/use_new_poll_api --- .../main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 5c673a5..7a5485b 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 @@ -210,7 +210,7 @@ import java.util.regex.Pattern; * KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props); * consumer.subscribe(Arrays.asList("foo", "bar")); * while (true) { - * ConsumerRecords<String, String> records = consumer.poll(100); + * ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100)); * for (ConsumerRecord<String, String> record : records) * System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value()); * } @@ -249,7 +249,7 @@ import java.util.regex.Pattern; * final int minBatchSize = 200; * List<ConsumerRecord<String, String>> buffer = new ArrayList<>(); * while (true) { - * ConsumerRecords<String, String> records = consumer.poll(100); + * ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100); * for (ConsumerRecord<String, String> record : records) { * buffer.add(record); * } @@ -288,7 +288,7 @@ import java.util.regex.Pattern; * 
  *     try {
  *         while(running) {
- *             ConsumerRecords<String, String> records = consumer.poll(Long.MAX_VALUE);
+ *             ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(Long.MAX_VALUE));
  *             for (TopicPartition partition : records.partitions()) {
  *                 List<ConsumerRecord<String, String>> partitionRecords = records.records(partition);
  *                 for (ConsumerRecord<String, String> record : partitionRecords) {