summaryrefslogtreecommitdiff
path: root/test/test_producer_integration.py
Commit message (Collapse)AuthorAgeFilesLines
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-111-529/+0
| | | | | | | | | | | | | | | | | | In the 2.0 release, we're removing: * `SimpleClient` * `SimpleConsumer` * `SimpleProducer` * Old partitioners used by `SimpleProducer`; these are superceded by the `DefaultPartitioner` These have been deprecated for several years in favor of `KafkaClient` / `KafkaConsumer` / `KafkaProducer`. Since 2.0 allows breaking changes, we are removing the deprecated classes. Additionally, since the only usage of `unittest` was in tests for these old Simple* clients, this also drops `unittest` from the library. All tests now run under `pytest`.
* Add KAFKA 2.3.0 to test matrix (#1915)Dana Powers2019-09-301-1/+3
|
* Cleanup handling of KAFKA_VERSION env var in tests (#1887)Jeff Widman2019-08-221-4/+4
| | | | | | | | | | | | | 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
|
* Vendor `six` consistentlyJeff Widman2018-10-221-1/+1
| | | | Use vendored `six`, and also `six.moves.range` rather than `xrange`
* Skip flakey SimpleProducer testDana Powers2018-04-181-0/+1
|
* Change SimpleProducer to use async_send (async is reserved in py37) (#1454)Dana Powers2018-03-231-4/+4
|
* Fix skipped integration tests if KAFKA_VERSION unset (#1453)Dana Powers2018-03-221-0/+6
|
* Introduce new fixtures to prepare for migration to pytest.Andre Araujo2018-02-211-19/+45
| | | | | | | This commits adds new pytest fixtures in prepation for the migration of unittest.TestCases to pytest test cases. The handling of temporary dir creation was also changed so that we can use the pytest tmpdir fixture after the migration.
* Reduce batch time in producer integration test (speedup test)Dana Powers2016-04-081-2/+5
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-4/+2
|
* Remove errant kafka_versions('all') from 0.9 mergeDana Powers2016-01-071-1/+0
|
* Merge branch '0.9'Dana Powers2016-01-071-3/+4
|\ | | | | | | | | | | | | | | Conflicts: kafka/codec.py kafka/version.py test/test_producer.py test/test_producer_integration.py
| * Remove bytes encoding for topic name in producer integration testDana Powers2015-12-101-1/+1
| |
| * Drop kafka_bytestringDana Powers2015-12-101-2/+2
| |
| * Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-091-3/+3
| |
* | Add producer integration test for SimpleProducer handling new topic creationDana Powers2015-12-161-9/+6
| |
* | Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)kafka_version_testsDana Powers2015-12-101-20/+1
|/
* Use producer.stop() to flush messages in async producer testDana Powers2015-12-051-4/+2
|
* Add KeyedProducer test with null payloadsViktor Shlapakov2015-06-171-0/+22
|
* Import style nits in integration testsDana Powers2015-06-081-0/+1
|
* Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-081-10/+10
|\ | | | | Deprecate KeyedProducer.send in favor of send_messages
| * Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵Dana Powers2015-05-171-10/+10
| | | | | | | | consistent
* | Deprecate async producer batch_send kwarg -- use 'async' insteadDana Powers2015-06-061-2/+2
| |
* | Small hanging indent style nits in some producer integration testsDana Powers2015-06-061-4/+8
| |
* | test_batched_simple_producer__triggers_by_message should wait for producer ↵Dana Powers2015-06-061-0/+10
|/ | | | queue to drain before testing messages were sent
* Make external API consistently support python3 strings for topic.Space2015-04-031-2/+2
|
* Correct message keys for async batching modeViktor Shlapakov2015-02-251-8/+8
|
* Reorganize producer integration tests; protect against non-sorted partition ↵Dana Powers2015-02-091-121/+160
| | | | metadata
* Use a different topic for each producer integration test for isolationDana Powers2015-02-091-1/+0
|
* Updated unittests to explicitly set random_start valueAlex Couture-Beil2015-01-091-15/+21
|
* Merge conflict w/ assertEqual (assertEquals deprecated)Dana Powers2014-12-151-10/+10
|
* Fixed TestKafkaProducerIntegrationLou Marvin Caraig2014-11-261-17/+25
|
* Use b''.join([]) instead of += to speedup codeDana Powers2014-09-101-0/+2
|
* Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-081-2/+4
|\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Metadata Refactor * add MetadataRequest and MetadataResponse namedtuples * add TopicMetadata namedtuple * add error codes to Topic and Partition Metadata * add KafkaClient.send_metadata_request() method * KafkaProtocol.decode_metadata_response changed to return a MetadataResponse object so that it is consistent with server api: [broker_list, topic_list] * raise server exceptions in load_metadata_for_topics(*topics) unless topics is null (full refresh) * Replace non-standard exceptions (LeaderUnavailable, PartitionUnavailable) with server standard exceptions (LeaderNotAvailableError, UnknownTopicOrPartitionError) Conflicts: kafka/client.py test/test_client.py test/test_producer_integration.py test/test_protocol.py
| * Refactor internal metadata dicts in KafkaClientDana Powers2014-09-011-1/+2
| | | | | | | | | | | | | | | | - use helper methods not direct access - add get_partition_ids_for_topic - check for topic and partition errors during load_metadata_for_topics - raise LeaderNotAvailableError when topic is being auto-created or UnknownTopicOrPartitionError if auto-creation off
* | Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-12/+22
|\ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * | Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-031-10/+20
| | |
| * | 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
| |/
* | Cleanup tests: no more import *; remove unusedDana Powers2014-09-041-7/+2
| |
* | Import cleanups in testsDana Powers2014-09-041-4/+11
|/
* Fix Py26 test casesMark Roberts2014-05-221-1/+1
|
* Handle New Topic CreationMark Roberts2014-05-221-0/+9
| | | | | Adds ensure_topic_exists to KafkaClient, redirects test case to use that. Fixes #113 and fixes #150.
* Merge branch 'master' into add_testsMark Roberts2014-05-061-6/+24
| | | | | | | | | | kafka/client.py contained duplicate copies of same refactor, merged. Move test/test_integration.py changes into test/test_producer_integration. Conflicts: kafka/client.py servers/0.8.0/kafka-src test/test_integration.py
* Fix Python 2.6 supportMark Roberts2014-04-231-1/+0
|
* Split out kafka version environments, default tox no longer runs any ↵Mark Roberts2014-04-231-2/+25
| | | | integration tests, make skipped integration also skip setupClass, implement rudimentary offset support in consumer.py
* Add test support for multiple versions of kafka. Uncomment first 0.8.1 ↵Mark Roberts2014-04-231-2/+2
| | | | specific test. Add rudimentary (failing) consumer resumption test
* Update fixtures to eliminate extraneous logging on non-errors, split out ↵Mark Roberts2014-04-221-0/+1
| | | | mostly unrelated service.py, fix test in client_integration to use get_open_port, fix unintended import cascade in test_producer_integration
* Split up and speed up producer based integration testsMark Roberts2014-04-171-71/+295
|
View Lorry Controller Status