| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Disable pylint error on __iter__ (next is provided via six.Iterator) | Dana Powers | 2016-01-03 | 1 | -1/+1 |
| | | |||||
| * | Batched message methods now return dict of lists | Dana Powers | 2016-01-02 | 1 | -2/+2 |
| | | |||||
| * | Improve iterator interface | Dana Powers | 2016-01-02 | 1 | -6/+22 |
| | | | | | | | | | - Support single message consumption via next(consumer) in py2/py3 - batch message methods (Fetcher.fetched_records / KafkaConsumer.poll) are incompatible with iterators -- message generator state keeps messages internally after they are popped from _records, but before subscription_state is updated. | ||||
| * | Improve request pipelining in consumer iterator | Dana Powers | 2015-12-31 | 1 | -13/+25 |
| | | |||||
| * | Support message decompression | Dana Powers | 2015-12-31 | 1 | -19/+15 |
| | | |||||
| * | Support simple message iteration in Fetcher and new KafkaConsumer | Dana Powers | 2015-12-30 | 1 | -0/+49 |
| | | |||||
| * | Prefer assert or more-specific error to IllegalState / IllegalArgument | Dana Powers | 2015-12-30 | 1 | -13/+7 |
| | | |||||
| * | More Docstring Improvements | Dana Powers | 2015-12-30 | 1 | -39/+94 |
| | | |||||
| * | Switch configs from attributes to dict to make passing / inspecting easier | Dana Powers | 2015-12-29 | 1 | -25/+25 |
| | | |||||
| * | New class: kafka.consumer.fetcher.Fetcher | Dana Powers | 2015-12-28 | 1 | -0/+523 |
| - manages fetch requests via async client and subscription_state - based on upstream java client | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |