| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Cleanup new producer tests...async_producer_connect_errors | Dana Powers | 2015-12-04 | 1 | -6/+6 |
| | | |||||
| * | client.reinit() can raise an exception; catch in async producer | Dana Powers | 2015-12-04 | 1 | -2/+10 |
| | | |||||
| * | Update kafka broker list for travis testing (add 0.9.0.0, bump 0.8.2.2) | Dana Powers | 2015-12-04 | 1 | -1/+2 |
| | | |||||
| * | Update setup.py to show python 3.5 compatibility explicitly | Dana Powers | 2015-12-04 | 1 | -0/+1 |
| | | |||||
| * | Add py35 to tox testing | Dana Powers | 2015-12-04 | 2 | -5/+9 |
| | | | | | | move python3 configs to default and special case py26/py27 add py35 to travis_selector.sh | ||||
| * | Cache pip and servers/ for travis builds | Dana Powers | 2015-12-04 | 1 | -0/+5 |
| | | |||||
| * | Update travis config to use container infrastructure | Dana Powers | 2015-12-04 | 1 | -4/+8 |
| | | |||||
| * | Add 0.8.2.2 and 0.9.0.0 resources for integration tests; update default ↵ | Dana Powers | 2015-12-04 | 7 | -1/+339 |
| | | | | | official releases | ||||
| * | Update docs and links wrt maintainer change (mumrah -> dpkp) | Dana Powers | 2015-12-03 | 5 | -25/+55 |
| | | |||||
| * | Merge pull request #481 from zackdever/pylint-1.5-changes | Dana Powers | 2015-12-03 | 3 | -3/+3 |
| |\ | | | | | new pylint disables for pylint 1.5.1 | ||||
| | * | new pylint disables for pylint 1.5.1 | Zack Dever | 2015-12-02 | 3 | -3/+3 |
| |/ | | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds. | ||||
| * | Merge pull request #420 from toddpalino/master | Dana Powers | 2015-12-02 | 4 | -7/+226 |
| |\ | | | | | Initial support for consumer coordinator | ||||
| | * | Fix misnamed node to nodeId in test | tpalino | 2015-07-02 | 1 | -1/+1 |
| | | | |||||
| | * | Add missing import for ConsumerMetadataResponse | tpalino | 2015-07-01 | 1 | -1/+1 |
| | | | |||||
| | * | Support consumer metadata requests | tpalino | 2015-07-01 | 4 | -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/Queue | Dana Powers | 2015-12-02 | 2 | -10/+10 |
| | | | |||||
| * | | Add Murmur2Partitioner to kafka __all__ imports - fix issue 471 | Dana Powers | 2015-12-02 | 1 | -1/+1 |
| | | | |||||
| * | | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests | Dana Powers | 2015-12-02 | 3 | -18/+52 |
| |\ \ | | | | | | | Use unblocking io for broker aware requests | ||||
| | * | | Add tests. Bug fix. Rename socket_conn dict. | Enrico Canzonieri | 2015-11-10 | 2 | -7/+24 |
| | | | | |||||
| | * | | Unblocking broker aware request | Enrico Canzonieri | 2015-11-10 | 2 | -18/+35 |
| | | | | |||||
| * | | | Merge pull request #467 from bschopman/master | Dana Powers | 2015-12-02 | 2 | -2/+9 |
| |\ \ \ | | | | | | | | | Prevents crashing communication thread of async producer | ||||
| | * | | | Prevents crashing communication thread of async producer | Balthasar Schopman | 2015-10-22 | 2 | -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-messages | Dana Powers | 2015-12-02 | 3 | -11/+36 |
| |\ \ \ | | | | | | | | | Consumers get_messages: allow blocking until some messages are received | ||||
| | * | | | Consumers get_messages: allow blocking until some messages are received | Oskari Saarenmaa | 2015-09-18 | 3 | -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-configs | Dana Powers | 2015-12-02 | 1 | -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 Dever | 2015-08-13 | 1 | -2/+3 |
| | | |_|/ | |/| | | |||||
| * | | | | Merge pull request #456 from barricadeio/mp-retry | Dana Powers | 2015-12-02 | 3 | -46/+63 |
| |\ \ \ \ | | | | | | | | | | | Support retry semantics in MultiProcessConsumer | ||||
| | * | | | | Support retry semantics in MultiProcessConsumer | Ross Duggan | 2015-09-14 | 3 | -46/+63 |
| | | |/ / | |/| | | |||||
| * | | | | Merge pull request #454 from trbs/gzip_compressionlevel | Dana Powers | 2015-12-02 | 3 | -10/+17 |
| |\ \ \ \ | | | | | | | | | | | allow to specify compression level for codecs which support this | ||||
| | * | | | | allow to specify compression level for codecs which support this | trbs | 2015-09-12 | 3 | -10/+17 |
| | |/ / / | |||||
| * | | | | Merge pull request #441 from koobs/patch-1 | Dana Powers | 2015-12-02 | 1 | -0/+1 |
| |\ \ \ \ | | | | | | | | | | | Include LICENSE in PyPI sdist | ||||
| | * | | | | Include LICENSE in PyPI sdist | Kubilay Kocak | 2015-07-31 | 1 | -0/+1 |
| | | |/ / | |/| | | |||||
| * | | | | Merge pull request #439 from chrischamberlin/fix-murmur | Dana Powers | 2015-12-02 | 2 | -10/+35 |
| |\ \ \ \ | | | | | | | | | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3. | ||||
| | * | | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3. | Chris Chamberlin | 2015-07-28 | 2 | -10/+35 |
| | |/ / / | | | | | | | | | | | | | | | | | | | | | Avoid further type changes when Murmur2Partitioner is passed a byte array. Change leftover-bytes logic to match the Java switch statement, and add tests to verify that partition selection matches Java implementation. | ||||
| * | | | | Merge pull request #435 from docker-hub/fix-producer-cleanup-logic | Dana Powers | 2015-12-02 | 2 | -1/+15 |
| |\ \ \ \ | | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects | ||||
| | * | | | | Fixing https://github.com/mumrah/kafka-python/issues/434 | toli | 2015-07-24 | 2 | -1/+15 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped objects. added tests | ||||
| * | | | | | Merge pull request #418 from scrapinghub/mp_partition_info | Dana Powers | 2015-12-02 | 3 | -8/+10 |
| |\ \ \ \ \ | | | | | | | | | | | | | allow to retrieve partition info in mp consumer | ||||
| | * | | | | | allow to retrieve partition info in mp consumer | Martin Olveyra | 2015-06-29 | 3 | -8/+10 |
| | | |/ / / | |/| | | | |||||
| * | | | | | Merge pull request #409 from scrapinghub/feature-allow-null-payload | Dana Powers | 2015-12-02 | 3 | -5/+53 |
| |\ \ \ \ \ | |_|_|_|/ |/| | | | | Allow null payload for deletion feature | ||||
| | * | | | | Producer test fix for python3 | Viktor Shlapakov | 2015-06-17 | 1 | -1/+1 |
| | | | | | | |||||
| | * | | | | Add KeyedProducer test with null payloads | Viktor Shlapakov | 2015-06-17 | 1 | -0/+22 |
| | | | | | | |||||
| | * | | | | Add basic keyed producer tests | Viktor Shlapakov | 2015-06-17 | 1 | -2/+22 |
| | | | | | | |||||
| | * | | | | Exclude (null,null) pair for producer | Viktor Shlapakov | 2015-06-17 | 1 | -3/+9 |
| | | | | | | |||||
| | * | | | | Allow null payload for deletion feature | Viktor Shlapakov | 2015-06-16 | 1 | -1/+1 |
| | | | | | | |||||
| * | | | | | Merge pull request #436 from mutability/async-catch-unavailable-error | Dana Powers | 2015-10-07 | 1 | -6/+11 |
| |\ \ \ \ \ | |_|_|_|/ |/| | | | | Catch KafkaUnavailableError in _send_broker_aware_request | ||||
| | * | | | | Init responses before we use it. | Oliver Jowett | 2015-07-24 | 1 | -1/+1 |
| | | | | | | |||||
| | * | | | | Errors -> Error typo | Oliver Jowett | 2015-07-20 | 1 | -1/+1 |
| | | | | | | |||||
| | * | | | | Treat KafkaUnavailableError like other errors. | Oliver Jowett | 2015-07-19 | 1 | -5/+10 |
| | | |/ / | |/| | | |||||
| * | | | | Merge pull request #432 from ecanzonieri/lower_logging_level_metadata | Dana Powers | 2015-08-24 | 1 | -2/+2 |
| |\ \ \ \ | |/ / / |/| | | | Use debug logging level for metadata request | ||||
| | * | | | Use debug logging level for metadata request | Enrico Canzonieri | 2015-07-21 | 1 | -2/+2 |
| |/ / / | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |