summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)kafka_version_testsDana Powers2015-12-105-56/+47
* Fix _mp_consume queue variable name conflictDana Powers2015-12-091-2/+2
* Bump version for development of next releaseDana Powers2015-12-091-1/+1
* spelling fix in CHANGES.md and format fix in README.rstZack Dever2015-12-072-2/+2
* Remove inadvertent markdown in CHANGES.mdDana Powers2015-12-071-1/+1
* Release 0.9.5v0.9.5Dana Powers2015-12-072-2/+2
* Update README links (restructured not markdown)Dana Powers2015-12-071-6/+5
* Update docs for new releaseDana Powers2015-12-062-12/+20
* Include README.rst, CHANGES.md, and AUTHORS.md in manifestDana Powers2015-12-061-0/+3
* Update README linksDana Powers2015-12-061-7/+8
* Update README for new releaseDana Powers2015-12-061-8/+14
* Add KafkaConsumer.close() PR to CHANGESDana Powers2015-12-061-0/+1
* Merge pull request #426 from ucarion/ucarion-kafkaconsumer-closeDana Powers2015-12-061-0/+4
|\
| * Add KafkaConsumer#closeUlysse Carion2015-07-071-0/+4
* | Update Changelog in preparation for 0.9.5 releaseDana Powers2015-12-061-0/+37
* | Log deprecation warning for timeout argument in Producer.stop()Dana Powers2015-12-061-3/+7
* | Merge pull request #485 from dpkp/async_producer_stopDana Powers2015-12-053-16/+15
|\ \
| * | Producer.stop() now blocks until async thread completes (drop confusing timeo...async_producer_stopDana Powers2015-12-051-7/+12
| * | Revert broken send_produce_request try/except from PR 467 (resps=None)Dana Powers2015-12-051-5/+1
| * | Use producer.stop() to flush messages in async producer testDana Powers2015-12-051-4/+2
|/ /
* | Fix requestId handling in send_broker_aware_requestDana Powers2015-12-041-2/+2
* | Cleanup new producer tests...async_producer_connect_errorsDana Powers2015-12-041-6/+6
* | client.reinit() can raise an exception; catch in async producerDana Powers2015-12-041-2/+10
* | Update kafka broker list for travis testing (add 0.9.0.0, bump 0.8.2.2)Dana Powers2015-12-041-1/+2
* | Update setup.py to show python 3.5 compatibility explicitlyDana Powers2015-12-041-0/+1
* | Add py35 to tox testingDana Powers2015-12-042-5/+9
* | Cache pip and servers/ for travis buildsDana Powers2015-12-041-0/+5
* | Update travis config to use container infrastructureDana Powers2015-12-041-4/+8
* | Add 0.8.2.2 and 0.9.0.0 resources for integration tests; update default offic...Dana Powers2015-12-047-1/+339
* | Update docs and links wrt maintainer change (mumrah -> dpkp)Dana Powers2015-12-035-25/+55
* | Merge pull request #481 from zackdever/pylint-1.5-changesDana Powers2015-12-033-3/+3
|\ \
| * | new pylint disables for pylint 1.5.1Zack Dever2015-12-023-3/+3
|/ /
* | Merge pull request #420 from toddpalino/masterDana Powers2015-12-024-7/+226
|\ \
| * | Fix misnamed node to nodeId in testtpalino2015-07-021-1/+1
| * | Add missing import for ConsumerMetadataResponsetpalino2015-07-011-1/+1
| * | Support consumer metadata requeststpalino2015-07-014-6/+225
| |/
* | Fix python3 / python2 comments re queue/QueueDana Powers2015-12-022-10/+10
* | Add Murmur2Partitioner to kafka __all__ imports - fix issue 471Dana Powers2015-12-021-1/+1
* | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requestsDana Powers2015-12-023-18/+52
|\ \
| * | Add tests. Bug fix. Rename socket_conn dict.Enrico Canzonieri2015-11-102-7/+24
| * | Unblocking broker aware requestEnrico Canzonieri2015-11-102-18/+35
* | | Merge pull request #467 from bschopman/masterDana Powers2015-12-022-2/+9
|\ \ \
| * | | Prevents crashing communication thread of async producerBalthasar Schopman2015-10-222-2/+9
| |/ /
* | | Merge pull request #457 from saaros/block-for-number-of-messagesDana Powers2015-12-023-11/+36
|\ \ \
| * | | Consumers get_messages: allow blocking until some messages are receivedOskari Saarenmaa2015-09-183-11/+36
* | | | Merge pull request #446 from zackdever/consumer-class-configsDana Powers2015-12-021-2/+3
|\ \ \ \
| * | | | set default config on consumer class to support subclass config changes.Zack Dever2015-08-131-2/+3
| | |_|/ | |/| |
* | | | Merge pull request #456 from barricadeio/mp-retryDana Powers2015-12-023-46/+63
|\ \ \ \
| * | | | Support retry semantics in MultiProcessConsumerRoss Duggan2015-09-143-46/+63
| | |/ / | |/| |
* | | | Merge pull request #454 from trbs/gzip_compressionlevelDana Powers2015-12-023-10/+17
|\ \ \ \