Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Fix KafkaClient->SimpleClient references0.9 | Dana Powers | 2016-01-07 | 1 | -5/+5 |
| | |||||
* | Import queue from six.moves | Dana Powers | 2016-01-03 | 1 | -10/+3 |
| | |||||
* | Rename TopicAndPartition -> TopicPartition | Dana Powers | 2015-12-28 | 1 | -5/+5 |
| | |||||
* | Update references to kafka.common Request/Response (now Payload) | Dana Powers | 2015-12-09 | 1 | -5/+5 |
| | |||||
* | Cleanup new producer tests...async_producer_connect_errors | Dana Powers | 2015-12-04 | 1 | -6/+6 |
| | |||||
* | Merge pull request #435 from docker-hub/fix-producer-cleanup-logic | Dana Powers | 2015-12-02 | 1 | -0/+14 |
|\ | | | | | 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 | 1 | -0/+14 |
| | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped objects. added tests | ||||
* | | Producer test fix for python3 | Viktor Shlapakov | 2015-06-17 | 1 | -1/+1 |
| | | |||||
* | | Add basic keyed producer tests | Viktor Shlapakov | 2015-06-17 | 1 | -2/+22 |
|/ | |||||
* | Support sync_fail_on_error kwarg in Producer | Dana Powers | 2015-06-09 | 1 | -2/+18 |
| | |||||
* | Add Unit test for async producer leader change; return ProduceResponse on ↵ | Dana Powers | 2015-06-09 | 1 | -10/+56 |
| | | | | success | ||||
* | Deprecate async producer batch_send kwarg -- use 'async' instead | Dana Powers | 2015-06-06 | 1 | -17/+0 |
| | |||||
* | FailedPayloadsError now only has a single payload; use .payload attribute | Dana Powers | 2015-06-06 | 1 | -2/+2 |
| | | | | .failed_payloads attribute has been removed. | ||||
* | Check response.error for async producer | Viktor Shlapakov | 2015-06-03 | 1 | -2/+2 |
| | |||||
* | Improve async producer code: logic and style fixes | Viktor Shlapakov | 2015-06-03 | 1 | -33/+20 |
| | | | | | | | | | | - send_producer_request with fail_on_error=False to retry failed reqs only - using an internal dict with with namedtuple keys for retry counters - refresh metadata on refresh_error irrespective to retries options - removed infinite retries (retry_options.limit=None) as an over-feature - separate producer init args for retries options (limit,backoff,on_timeouts) - AsyncProducerQueueFull returns a list of failed messages - producer tests improved thanks to @rogaha and @toli | ||||
* | Increase producer test timeout | Viktor Shlapakov | 2015-06-03 | 1 | -1/+1 |
| | |||||
* | Fix small issues with names/tests | Viktor Shlapakov | 2015-06-03 | 1 | -7/+5 |
| | |||||
* | async queue: refactored code; add one more test | Eduard Iskandarov | 2015-06-03 | 1 | -2/+16 |
| | |||||
* | add producer send batch queue overfilled test | Искандаров Эдуард | 2015-06-03 | 1 | -1/+17 |
| | |||||
* | Clean and simplify retry logic | Viktor Shlapakov | 2015-06-03 | 1 | -3/+5 |
| | |||||
* | Improved retry logic | Viktor Shlapakov | 2015-06-03 | 1 | -3/+3 |
| | |||||
* | Fixed tests and other issues after rebase | Viktor Shlapakov | 2015-06-03 | 1 | -30/+19 |
| | |||||
* | Fixed compatible issues with tests | Viktor Shlapakov | 2015-06-03 | 1 | -12/+11 |
| | |||||
* | Producer _send_upstream fixes, added tests for retries | Viktor Shlapakov | 2015-06-03 | 1 | -0/+137 |
| | |||||
* | Just encode to bytes if it isn't bytes. | John Anderson | 2015-01-24 | 1 | -6/+10 |
| | |||||
* | Alert if the topic is not sent as bytes | John Anderson | 2015-01-23 | 1 | -0/+11 |
| | |||||
* | Separate consumers/producers/partitioners | Dana Powers | 2014-09-10 | 1 | -1/+1 |
| | |||||
* | Merge pull request #227 from wizzat-feature/py3 | Dana Powers | 2014-09-07 | 1 | -5/+5 |
|\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Python 3 Support Conflicts: kafka/producer.py test/test_client.py test/test_client_integration.py test/test_codec.py test/test_consumer.py test/test_consumer_integration.py test/test_failover_integration.py test/test_producer.py test/test_producer_integration.py test/test_protocol.py test/test_util.py | ||||
| * | More bytes topics | Bruno Renié | 2014-09-03 | 1 | -1/+1 |
| | | |||||
| * | Make all unit tests pass on py3.3/3.4 | Bruno Renié | 2014-09-03 | 1 | -2/+2 |
| | | |||||
| * | Use base unittest or unittest2 depending on python version | Bruno Renié | 2014-09-03 | 1 | -2/+2 |
| | | |||||
* | | Cleanup tests: no more import *; remove unused | Dana Powers | 2014-09-04 | 1 | -6/+2 |
|/ | |||||
* | Add producer unit test (test/test_producer.py); check supported types in ↵ | Dana Powers | 2014-08-26 | 1 | -0/+31 |
send_messages |