diff options
| author | Omar Ghishan <omar.ghishan@rd.io> | 2013-12-18 17:51:22 -0800 |
|---|---|---|
| committer | Omar Ghishan <omar.ghishan@rd.io> | 2014-01-06 15:14:50 -0800 |
| commit | 8c8ca5fa573c21e0f03c892154ba42e187153600 (patch) | |
| tree | 5939b4442eb8e72c76f3f48bf9f874d8eb2a0aad /kafka/protocol.py | |
| parent | 0f2b08d80217fb82860c51e05e819012f6acb521 (diff) | |
| download | kafka-python-8c8ca5fa573c21e0f03c892154ba42e187153600.tar.gz | |
* Guarantee reading the expected number of bytes from the socket every time
* Remove bufsize from client and conn, since they're not actually enforced
Notes:
This commit changes behavior a bit by raising a BufferUnderflowError when
no data is received for the message size rather than a ConnectionError.
Since bufsize in the socket is not actually enforced, but it is used by the consumer
when creating requests, moving it there until a better solution is implemented.
Diffstat (limited to 'kafka/protocol.py')
0 files changed, 0 insertions, 0 deletions