summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)simpleDana Powers2015-12-301-0/+2
|
* Remove old kafka-bin directory and verify kafka-run-class.sh exists when ↵Dana Powers2015-12-181-0/+6
| | | | installing server artifacts
* Only download/install server artifacts if bin/kafka-run-class.sh not foundDana Powers2015-12-181-5/+6
|
* Retry on FailedPayloadsError from consumer.pending() in failover testsDana Powers2015-12-181-4/+5
|
* Merge pull request #490 from mre/patch-1Dana Powers2015-12-181-1/+1
|\ | | | | Fix typo in docblock
| * Fix typo in docblockMatthias Endler2015-12-181-1/+1
|/
* Merge pull request #489 from dpkp/producer_new_topicDana Powers2015-12-173-20/+18
|\ | | | | Handle new topic auto-creation in SimpleProducer.send_messages
| * Mock client.ensure_topic_exists in test_producer_sync_fail_on_errorproducer_new_topicDana Powers2015-12-171-10/+11
| |
| * Handle new topic creation / LeaderNotAvailableError in initial ↵Dana Powers2015-12-161-1/+1
| | | | | | | | SimpleProducer.send_messages call
| * Add producer integration test for SimpleProducer handling new topic creationDana Powers2015-12-161-9/+6
|/
* Merge pull request #487 from dpkp/kafka_version_testsDana Powers2015-12-105-56/+47
|\ | | | | Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)
| * 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#close
| * 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() should block until async thread completes
| * | Producer.stop() now blocks until async thread completes (drop confusing ↵async_producer_stopDana Powers2015-12-051-7/+12
| | | | | | | | | | | | timeout arg)
| * | 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
| | | | | | | | | | move python3 configs to default and special case py26/py27 add py35 to travis_selector.sh
* | 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 ↵Dana Powers2015-12-047-1/+339
| | | | | | | | official releases
* | 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.1
| * | new pylint disables for pylint 1.5.1Zack Dever2015-12-023-3/+3
|/ / | | | | | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds.
* | Merge pull request #420 from toddpalino/masterDana Powers2015-12-024-7/+226
|\ \ | | | | | | Initial support for consumer coordinator
| * | 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
| |/ | | | | | | | | | | Support added for ConsumerMetadataRequest and ConsumerMetadataResponse Added consumer-aware request routine for supporting the consumer coordinator Added separate client method for fetching Kafka-committed offsets from the coordinator
* | 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
|\ \ | | | | | | Use unblocking io for broker aware requests
View Lorry Controller Status