summaryrefslogtreecommitdiff
path: root/test/test_producer_integration.py
Commit message (Collapse)AuthorAgeFilesLines
* 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