summaryrefslogtreecommitdiff
path: root/test/test_producer.py
Commit message (Expand)AuthorAgeFilesLines
* Add support for `zstd` compression (#2021)Tincu Gabriel2020-09-071-10/+10
* Cleanup handling of KAFKA_VERSION env var in tests (#1887)Jeff Widman2019-08-221-5/+5
* Use test.fixtures.version not test.conftest.version to avoid warnings (#1731)Dana Powers2019-03-061-2/+1
* Be explicit with tuples for %s formattingJeff Widman2018-11-181-1/+1
* Cleanup fixture importsJeff Widman2018-10-271-1/+1
* Support produce with Kafka record headersHeikki Nousiainen2018-09-271-1/+9
* Close KafkaConsumer instances during tests (#1410)Dana Powers2018-03-081-1/+1
* Increase some integration test timeouts (#1374)Dana Powers2018-02-081-3/+3
* Minor test cleanups (#1343)Dana Powers2018-01-121-0/+1
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...Taras Voinarovskyi2017-10-251-5/+4
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-221-2/+52
* Use fixture hostname (dont assume localhost)Dana Powers2017-06-181-1/+1
* Alter test skips: python-lz4 works on python26, but not pypyDana Powers2017-03-141-2/+2
* Fix typosJeff Widman2016-11-141-1/+1
* Use weakref when registering a producer.close atexit to fix normal gc (#728)Dana Powers2016-06-181-0/+14
* Reduce end-to-end test to 100 messages; raise produce future exceptions immed...Dana Powers2016-03-131-5/+9
* 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
|\
| * 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
|\
| * Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-241-0/+14
* | 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 suc...Dana Powers2015-06-091-10/+56
* 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
* Check response.error for async producerViktor Shlapakov2015-06-031-2/+2
* Improve async producer code: logic and style fixesViktor Shlapakov2015-06-031-33/+20
* 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
View Lorry Controller Status