summaryrefslogtreecommitdiff
Commit message (Collapse)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#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
| * | 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 producer
| * | | Prevents crashing communication thread of async producerBalthasar Schopman2015-10-222-2/+9
| |/ / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | If an uncaught exception occurs in _send_messages() the thread sending data to Kafka (asynchronously) will crash and the queue will never be emptied. To reproduce: 1) Run an Async producer. 2) Kill the Kafka server. 3) Restart the Kafka server. The communication thread dies shortly after step 2. After step 3 the communication does not resume without this commit. The changes in both files prevent an Exception from being thrown through to do main communication process, which could cause the crash.
* | | 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 received
| * | | Consumers get_messages: allow blocking until some messages are receivedOskari Saarenmaa2015-09-183-11/+36
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Modified MultiProcessConsumer's and SimpleConsumer's `block` argument to allow integer value which defines the number of messages to block for. This allows callers to ask for a high number of messages and block only until some of them are received. Otherwise callers would have to request messages one by one or block for some time.
* | | | 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.
| * | | | 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 MultiProcessConsumer
| * | | | Support retry semantics in MultiProcessConsumerRoss Duggan2015-09-143-46/+63
| | |/ / | |/| |
* | | | Merge pull request #454 from trbs/gzip_compressionlevelDana Powers2015-12-023-10/+17
|\ \ \ \ | | | | | | | | | | allow to specify compression level for codecs which support this
View Lorry Controller Status