summaryrefslogtreecommitdiff
path: root/test/test_producer.py
Commit message (Collapse)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
| | | | | | | | | | | | | Now that we are using `pytest`, there is no need for a custom decorator because we can use `pytest.mark.skipif()`. This makes the code significantly simpler. In particular, dropping the custom `@kafka_versions()` decorator is necessary because it uses `func.wraps()` which doesn't play nice with `pytest` fixtures: - https://github.com/pytest-dev/pytest/issues/677 - https://stackoverflow.com/a/19614807/770425 So this is a pre-requisite to migrating some of those tests to using pytest fixtures.
* 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
| | | | Fix #1633
* Cleanup fixture importsJeff Widman2018-10-271-1/+1
| | | | | | | | | | | | | | | `random_string` now comes from `test.fixtures` and was being transparently imported via `test.testutil` so this bypasses the pointless indirect import. Similarly, `kafka_version` was transparently imported by `test.testutil` from `test.fixtures`. Also removed `random_port()` in `test.testutil` because its unused as its been replaced by the one in `test.fixtures`. This is part of the pytest migration that was started back in a1869c4be5f47b4f6433610249aaf29af4ec95e5.
* 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
| | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-221-2/+52
| | | | | | | | * Fix timestamp not being passed to RecordMetadata properly * Add more tests for LegacyBatch * Fix producer test for recordmetadata
* 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
| | | | * 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
|
View Lorry Controller Status