summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
authorDavid Arthur <mumrah@gmail.com>2013-09-08 20:20:12 -0400
committerDavid Arthur <mumrah@gmail.com>2013-09-08 20:20:12 -0400
commit40d8e9e550b48755e2f40cfd0877a5b848a3254f (patch)
treee634245b6b0a52e40c9e03359413512feac252ed /kafka/client.py
parentc3bce13b845999483f7601836a2e7681dcd8ff10 (diff)
downloadkafka-python-40d8e9e550b48755e2f40cfd0877a5b848a3254f.tar.gz
Fixed #42, make fetch size configurable
Was hard coded to 1024 bytes which meant that larger messages were unconsumable since they would always get split causing the consumer to stop. It would probably be best to automatically retry truncated messages with a larger request size so you don't have to know your max message size ahead of time
Diffstat (limited to 'kafka/client.py')
0 files changed, 0 insertions, 0 deletions