summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* 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
|\ \ \ \
| * | | | allow to specify compression level for codecs which support thistrbs2015-09-123-10/+17
| |/ / /
* | | | Merge pull request #441 from koobs/patch-1Dana Powers2015-12-021-0/+1
|\ \ \ \
| * | | | Include LICENSE in PyPI sdistKubilay Kocak2015-07-311-0/+1
| | |/ / | |/| |
* | | | Merge pull request #439 from chrischamberlin/fix-murmurDana Powers2015-12-022-10/+35
|\ \ \ \
| * | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3.Chris Chamberlin2015-07-282-10/+35
| |/ / /
* | | | Merge pull request #435 from docker-hub/fix-producer-cleanup-logicDana Powers2015-12-022-1/+15
|\ \ \ \
| * | | | Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-242-1/+15
* | | | | Merge pull request #418 from scrapinghub/mp_partition_infoDana Powers2015-12-023-8/+10
|\ \ \ \ \
| * | | | | allow to retrieve partition info in mp consumerMartin Olveyra2015-06-293-8/+10
| | |/ / / | |/| | |
* | | | | Merge pull request #409 from scrapinghub/feature-allow-null-payloadDana Powers2015-12-023-5/+53
|\ \ \ \ \ | |_|_|_|/ |/| | | |
| * | | | Producer test fix for python3Viktor Shlapakov2015-06-171-1/+1