| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 1 | -0/+2 |
| | | |||||
| * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Use weakref when registering a producer.close atexit to fix normal gc (#728) | Dana Powers | 2016-06-18 | 1 | -0/+10 |
| | | | | | * Use weakref when registering a producer.close atexit to fix normal gc * Test that del(producer) terminates async thread | ||||
| * | Update imports from kafka.common -> kafka.errors / kafka.structs | Dana Powers | 2016-04-05 | 1 | -1/+1 |
| | | |||||
| * | break up some circular references and close client wake pipe on __del__ | aisch | 2016-02-16 | 1 | -0/+37 |
| | | |||||
| * | Drop kafka_bytestring | Dana Powers | 2015-12-10 | 1 | -12/+0 |
| | | |||||
| * | Switch crc32 back to signed integer -- this is consistent with protocol ↵ | Dana Powers | 2015-12-04 | 1 | -1/+7 |
| | | | | | encoding spec | ||||
| * | Raise an error if we attempt to group duplicate topic-partition payloads | Dana Powers | 2015-06-06 | 1 | -0/+3 |
| | | | | | - previously this would simply drop one of the payloads | ||||
| * | Stopping daemonized threads when references to these threads are lost | Christophe-Marie Duquesne | 2015-03-02 | 1 | -0/+3 |
| | | |||||
| * | Fix python2.6 threading.Event bug in ReentrantTimer | Dana Powers | 2015-02-03 | 1 | -1/+5 |
| | | |||||
| * | fix circle reference | zhaopengzp | 2015-02-02 | 1 | -0/+1 |
| | | |||||
| * | Add Sphinx API docs | Will Daly | 2015-01-15 | 1 | -4/+6 |
| | | |||||
| * | Use kafka.util.kafka_bytestring to encode utf-8 when necessary | Dana Powers | 2014-12-15 | 1 | -0/+12 |
| | | |||||
| * | Update kafka.util.crc32 to unsigned everywhere | Mark Roberts | 2014-09-03 | 1 | -11/+2 |
| | | |||||
| * | Make all unit tests pass on py3.3/3.4 | Bruno Renié | 2014-09-03 | 1 | -5/+21 |
| | | |||||
| * | Fix write_int and write_short type validation | Matthew L Daniel | 2014-08-22 | 1 | -0/+6 |
| | | | | | It will still die, just as before, but it now includes a *helpful* error message | ||||
| * | PEP8 fixes | Matthew L Daniel | 2014-08-22 | 1 | -1/+2 |
| | | |||||
| * | Attempt to fix travis build. Decrease complexity of service.py in favor of ↵ | Mark Roberts | 2014-05-06 | 1 | -2/+2 |
| | | | | | in memory logging. Address code review concerns | ||||
| * | Various fixes | Mark Roberts | 2014-04-25 | 1 | -2/+6 |
| | | | | | | | | | Bump version number to 0.9.1 Update readme to show supported Kafka/Python versions Validate arguments in consumer.py, add initial consumer unit test Make service kill() child processes when startup fails Add tests for util.py, fix Python 2.6 specific bug. | ||||
| * | flake8 pass (pep8 and pyflakes) | mrtheb | 2013-10-03 | 1 | -3/+3 |
| | | |||||
| * | style: remove extra brackets one more time | Vetoshkin Nikita | 2013-10-03 | 1 | -5/+5 |
| | | |||||
| * | style: fix camelCase variable names | Vetoshkin Nikita | 2013-10-03 | 1 | -12/+11 |
| | | | | | | | Conflicts: kafka/util.py | ||||
| * | Cherry-pick mrtheb/kafka-python 2b016b69 | mrtheb | 2013-10-03 | 1 | -3/+4 |
| | | | | | Set FetchRequest MaxBytes value to bufsize instead of fetchsize (=MinBytes) | ||||
| * | import bufferunderflow error | Jim Lim | 2013-09-27 | 1 | -0/+2 |
| | | |||||
| * | Fix #44 Add missing exception classv0.8.0 | David Arthur | 2013-09-24 | 1 | -9/+0 |
| | | | | | Also move the exceptions to common instead of util | ||||
| * | Auto-adjusting consumer fetch size | David Arthur | 2013-09-09 | 1 | -0/+2 |
| | | | | | | | | | | | | | | | | Related to #42 Adds new ConsumerFetchSizeTooSmall exception that is thrown when `_decode_message_set_iter` gets a BufferUnderflowError but has not yet yielded a message In this event, SimpleConsumer will increase the fetch size by 1.5 and continue the fetching loop while _not_ increasing the offset (basically just retries the request with a larger fetch size) Once the consumer fetch size has been increased, it will remain increased while SimpleConsumer fetches from that partition | ||||
| * | Fix an issue with thread argument | Mahendra M | 2013-06-12 | 1 | -1/+1 |
| | | |||||
| * | Optimize auto-commit thread | Mahendra M | 2013-06-12 | 1 | -12/+31 |
| | | | | | | | | | | | | | | The previous commit optimized the commit thread such that the timer started only when there were messages to be consumed. This commit goes a step further and ensures the following: * Only one timer thread is created * The main app does not block on exit (waiting for timer thread to finish) This is ensured by having a single thread blocking on an event and keeps calling a function. We use events instead of time.sleep() so as to prevent the python interpreter from running every 50ms checking if the timer has expired (logic copied from threading.Timer) | ||||
| * | Spawn the commit thread only if necessary | Mahendra M | 2013-06-11 | 1 | -0/+3 |
| | | | | | | | | If there are no messages being consumed, the timer keeps creating new threads at the specified intervals. This may not be necessary. We can control this behaviour such that the timer thread is started only when a message is consumed | ||||
| * | PEP8-ify most of the files | Mahendra M | 2013-05-29 | 1 | -17/+34 |
| | | | | | consumer.py and conn.py will be done later after pending merges | ||||
| * | Auto commit timer is not periodic | Mahendra M | 2013-05-28 | 1 | -6/+5 |
| | | | | | | | | The auto commit timer is one-shot. After the first commit, it does not fire again. This ticket fixes the issue. Also, in util.ReentrantTimer(), some duplicate code was cleaned up | ||||
| * | Big code re-org | David Arthur | 2013-04-02 | 1 | -0/+25 |
| | | |||||
| * | Integration tests passing | David Arthur | 2013-04-02 | 1 | -2/+2 |
| | | |||||
| * | Protocol and low-level client done, adding tests | David Arthur | 2013-04-02 | 1 | -8/+8 |
| | | |||||
| * | Fix a bunch of bugs | David Arthur | 2013-04-02 | 1 | -3/+6 |
| | | |||||
| * | First pass of cleanup/refactoring | David Arthur | 2013-04-02 | 1 | -8/+25 |
| | | | | | Also added a bunch of docstrings | ||||
| * | Starting work on 0.8 compat | David Arthur | 2013-04-02 | 1 | -0/+38 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |