diff options
| author | Taras Voinarovskyi <voyn1991@gmail.com> | 2016-11-20 22:37:01 +0200 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-11-20 12:37:01 -0800 |
| commit | 07237d98945f8e1f1161ab5082230d9112016620 (patch) | |
| tree | 9180e54d1caf1b76a9ce750ba2fa2b42b1c7f0f7 | |
| parent | af7f2ced1bfe2fc4f50887a05fcaa81afb49b59c (diff) | |
| download | kafka-python-07237d98945f8e1f1161ab5082230d9112016620.tar.gz | |
Added doc for `max_poll_records` option (#881)
| -rw-r--r-- | kafka/consumer/group.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 5550d54..02915b4 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -116,7 +116,8 @@ class KafkaConsumer(six.Iterator): rebalances. Default: 3000 session_timeout_ms (int): The timeout used to detect failures when using Kafka's group managementment facilities. Default: 30000 - max_poll_records (int): .... + max_poll_records (int): The maximum number of records returned in a + single call to poll(). 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. |