diff options
| author | Omar <omar.ghishan@rd.io> | 2014-01-13 13:52:02 -0800 |
|---|---|---|
| committer | Omar <omar.ghishan@rd.io> | 2014-01-13 13:52:02 -0800 |
| commit | 87c7f9dedfc008e3fff7a010cc4e708eeec5bebe (patch) | |
| tree | c55c3c5fea1fab6eef77f5213909ed2c2f8acc92 /example.py | |
| parent | 354fcdbdd9b34b3454b964e6dc0d4a746744bbcd (diff) | |
| parent | a0c7141e2cc7399a9472a8169ea5f730f0407386 (diff) | |
| download | kafka-python-87c7f9dedfc008e3fff7a010cc4e708eeec5bebe.tar.gz | |
Merge pull request #88 from rdiomar/rdiomar_changes
Various changes/fixes, including:
* Allow customizing socket timeouts
* Read the correct number of bytes from kafka
* Guarantee reading the expected number of bytes from the socket every time
* Remove bufsize from client and conn
* SimpleConsumer flow changes
* Fix some error handling
* Add optional upper limit to consumer fetch buffer size
* Add and fix unit and integration tests
Diffstat (limited to 'example.py')
0 files changed, 0 insertions, 0 deletions