diff options
Diffstat (limited to 'kafka/consumer.py')
| -rw-r--r-- | kafka/consumer.py | 3 |
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 |