From c921b2ac4cec7459f8a84a0583e8892e6b3f2c6f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Fri, 8 Jul 2016 16:04:09 -0700 Subject: Update consumer_timeout_ms docstring per #749 --- kafka/consumer/group.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'kafka') diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 72f9dc8..8509999 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -120,9 +120,9 @@ class KafkaConsumer(six.Iterator): receive_buffer_bytes (int): The size of the TCP receive buffer (SO_RCVBUF) to use when reading data. Default: None (relies on system defaults). The java client defaults to 32768. - consumer_timeout_ms (int): number of millisecond to throw a timeout - exception to the consumer if no message is available for - consumption. Default: -1 (dont throw exception) + consumer_timeout_ms (int): number of milliseconds to block during + message iteration before raising StopIteration (i.e., ending the + iterator). Default -1 (block forever). security_protocol (str): Protocol used to communicate with brokers. Valid values are: PLAINTEXT, SSL. Default: PLAINTEXT. ssl_context (ssl.SSLContext): pre-configured SSLContext for wrapping -- cgit v1.2.1