summaryrefslogtreecommitdiff
path: root/kafka/consumer.py
diff options
context:
space:
mode:
authorOmar Ghishan <omar.ghishan@rd.io>2013-12-19 13:19:40 -0800
committerOmar Ghishan <omar.ghishan@rd.io>2014-01-06 15:14:50 -0800
commit450faeb328fe085a35c70e0dcbf93cbd44277362 (patch)
tree6b286afd09128cb04be05cc92fffe759473be565 /kafka/consumer.py
parentb68523fd28dec0741a15cbb3b5a78d954c559d2d (diff)
downloadkafka-python-450faeb328fe085a35c70e0dcbf93cbd44277362.tar.gz
Add buffer_size param description to docstring
Diffstat (limited to 'kafka/consumer.py')
-rw-r--r--kafka/consumer.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py
index b27b845..7e53f08 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -207,8 +207,9 @@ class SimpleConsumer(Consumer):
before a commit
auto_commit_every_t: default 5000. How much time (in milliseconds) to
wait before commit
-
fetch_size_bytes: number of bytes to request in a FetchRequest
+ buffer_size: initial number of bytes to tell kafka we have
+ available. This will double every time it's not enough
Auto commit details:
If both auto_commit_every_n and auto_commit_every_t are set, they will