summaryrefslogtreecommitdiff
path: root/test/test_producer_integration.py
Commit message (Collapse)AuthorAgeFilesLines
* 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
|
* Split out and speed up producer testsMark Roberts2014-04-171-0/+139
View Lorry Controller Status