diff options
| author | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-03 15:49:55 -0800 |
|---|---|---|
| committer | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-06 15:14:51 -0800 |
| commit | bbd90e12ffd83e7ed845c488e21a7155c25f5b82 (patch) | |
| tree | e3963187fa7f8d2b7221210029b50bbacc9d0cb4 /test/test_integration.py | |
| parent | 8540f1f3b6b07f9ddb28d3ade78679a0ac2d4355 (diff) | |
| download | kafka-python-bbd90e12ffd83e7ed845c488e21a7155c25f5b82.tar.gz | |
Add a limit to fetch buffer size, and actually retry requests when fetch size is too small
Note: This can cause fetching a message to exceed a given timeout, but timeouts are not guaranteed anyways, and in this case it's the client's fault for not sending a big enough buffer size rather than the kafka server. This can be bad if max_fetch_size is None (no limit) and there is some message in Kafka that is crazy huge, but that is why we should have some max_fetch_size.
Diffstat (limited to 'test/test_integration.py')
0 files changed, 0 insertions, 0 deletions