summaryrefslogtreecommitdiff
path: root/test/test_producer.py
Commit message (Collapse)AuthorAgeFilesLines
* Use weakref when registering a producer.close atexit to fix normal gc (#728)Dana Powers2016-06-181-0/+14
| | | | * Use weakref when registering a producer.close atexit to fix normal gc * Test that del(producer) terminates async thread
* Reduce end-to-end test to 100 messages; raise produce future exceptions ↵Dana Powers2016-03-131-5/+9
| | | | immediately
* Add SimpleBufferPool test to verify reallocated buffers are emptyDana Powers2016-03-131-0/+13
|
* Use producer retries and flush timeout in producer end-to-end testDana Powers2016-03-131-1/+2
|
* Handle broken LZ4 framing; switch to lz4tools + xxhashlz4_fixupDana Powers2016-01-261-3/+9
|
* Add end-to-end integration testing for all compression typesDana Powers2016-01-261-1/+8
|
* Disable auto-commit / group assignment in producer testgroup_id_noneDana Powers2016-01-241-0/+1
|
* Add simple KafkaProducer -> KafkaConsumer integration testDana Powers2016-01-241-0/+34
|
* Rename legacy producer testsDana Powers2016-01-241-257/+0
|
* Merge branch '0.9'Dana Powers2016-01-071-25/+18
|\ | | | | | | | | | | | | | | Conflicts: kafka/codec.py kafka/version.py test/test_producer.py test/test_producer_integration.py
| * Fix KafkaClient->SimpleClient references0.9Dana Powers2016-01-071-5/+5
| |
| * Import queue from six.movesDana Powers2016-01-031-10/+3
| |
| * Rename TopicAndPartition -> TopicPartitionDana Powers2015-12-281-5/+5
| |
| * Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-091-5/+5
| |
* | Mock client.ensure_topic_exists in test_producer_sync_fail_on_errorproducer_new_topicDana Powers2015-12-171-10/+11
|/
* Cleanup new producer tests...async_producer_connect_errorsDana Powers2015-12-041-6/+6
|
* Merge pull request #435 from docker-hub/fix-producer-cleanup-logicDana Powers2015-12-021-0/+14
|\ | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects
| * Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-241-0/+14
| | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped objects. added tests
* | Producer test fix for python3Viktor Shlapakov2015-06-171-1/+1
| |
* | Add basic keyed producer testsViktor Shlapakov2015-06-171-2/+22
|/
* Support sync_fail_on_error kwarg in ProducerDana Powers2015-06-091-2/+18
|
* Add Unit test for async producer leader change; return ProduceResponse on ↵Dana Powers2015-06-091-10/+56
| | | | success
* Deprecate async producer batch_send kwarg -- use 'async' insteadDana Powers2015-06-061-17/+0
|
* FailedPayloadsError now only has a single payload; use .payload attributeDana Powers2015-06-061-2/+2
| | | | .failed_payloads attribute has been removed.
* Check response.error for async producerViktor Shlapakov2015-06-031-2/+2
|
* Improve async producer code: logic and style fixesViktor Shlapakov2015-06-031-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 timeoutViktor Shlapakov2015-06-031-1/+1
|
* Fix small issues with names/testsViktor Shlapakov2015-06-031-7/+5
|
* async queue: refactored code; add one more testEduard Iskandarov2015-06-031-2/+16
|
* add producer send batch queue overfilled testИскандаров Эдуард2015-06-031-1/+17
|
* Clean and simplify retry logicViktor Shlapakov2015-06-031-3/+5
|
* Improved retry logicViktor Shlapakov2015-06-031-3/+3
|
* Fixed tests and other issues after rebaseViktor Shlapakov2015-06-031-30/+19
|
* Fixed compatible issues with testsViktor Shlapakov2015-06-031-12/+11
|
* Producer _send_upstream fixes, added tests for retriesViktor Shlapakov2015-06-031-0/+137
|
* Just encode to bytes if it isn't bytes.John Anderson2015-01-241-6/+10
|
* Alert if the topic is not sent as bytesJohn Anderson2015-01-231-0/+11
|
* Separate consumers/producers/partitionersDana Powers2014-09-101-1/+1
|
* Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-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 topicsBruno Renié2014-09-031-1/+1
| |
| * Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-031-2/+2
| |
| * Use base unittest or unittest2 depending on python versionBruno Renié2014-09-031-2/+2
| |
* | Cleanup tests: no more import *; remove unusedDana Powers2014-09-041-6/+2
|/
* Add producer unit test (test/test_producer.py); check supported types in ↵Dana Powers2014-08-261-0/+31
send_messages
View Lorry Controller Status