summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
...
* Make external API consistently support python3 strings for topic.Space2015-04-036-45/+52
|
* Merge pull request #356 from dpkp/always_fetch_offsetsDana Powers2015-03-302-2/+75
|\ | | | | fetch commit offsets in base consumer unless group is None
| * Fetch previously committed offsets in base consumer class so long asDana Powers2015-03-302-2/+5
| | | | | | | | | | | | | | | | a group is configured (but document that group must be None for old servers). This fixes multiprocessor consumer issue that prevented access to commit offsets if auto_commit is disabled. Also refactor fetch_last_known_offsets based on KafkaConsumer While still setting unknown offsets to 0
| * Skip these tests: no OffsetCommitRequest for 0.8.0Viktor Shlapakov2015-03-301-2/+2
| |
| * Added basic tests for load_initial_offsets optionViktor Shlapakov2015-03-301-0/+35
| |
| * Add test case for MP Consumer auto commitAli-Akber Saifee2015-03-301-0/+35
| | | | | | | | Tweak MP Consumer test to use iterator
* | Merge pull request #355 from dpkp/correlation_id_moduloDana Powers2015-03-301-0/+8
|\ \ | |/ |/| correlation_id modulo
| * Add test for correlation_id rolloverDana Powers2015-03-291-0/+8
| |
* | Use bootstrap_servers interface in testsDana Powers2015-03-291-1/+1
|/
* Merge pull request #336 from scrapinghub/feature-mp-consumer-paramsDana Powers2015-03-291-2/+3
|\ | | | | Using additional params for MP consumer child process
| * Moving to **kwargs for MPConsumer optionsViktor Shlapakov2015-03-241-5/+3
| |
| * Using iter_timeout=0 for MP inner consumer in testsViktor Shlapakov2015-03-131-1/+4
| |
* | Merge pull request #329 from vshlapakov/feature-batch-msg-keysDana Powers2015-03-292-11/+71
|\ \ | |/ |/| Correct message keys for async batching mode
| * Correct message keys for async batching modeViktor Shlapakov2015-02-252-11/+71
| |
* | Merge branch 'vshlapakov-feature-async-threading'Dana Powers2015-03-081-0/+44
|\ \ | | | | | | | | | | | | | | | | | | PR 330: Threading for async batching Conflicts: kafka/producer/base.py
| * | Returned original tests, rm dirty flag, name fixesViktor Shlapakov2015-02-251-0/+44
| | |
* | | Merge pull request #296 from ecanzonieri/validate_consumer_offsetDana Powers2015-03-021-1/+43
|\ \ \ | |_|/ |/| | Validate consumer offset in SimpleConsumer
| * | Retry failed partitions and add integration testsEnrico Canzonieri2015-01-261-1/+43
| | |
* | | 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
| | |
* | | Add more comments to test_switch_leader regarding req_acks policyDana Powers2015-02-091-3/+10
| | |
* | | Write a test for issue 313 - keyed producer failoverDana Powers2015-02-091-0/+40
| | |
* | | use setUp / tearDown to rebuild fixtures for each test in ↵Dana Powers2015-02-091-12/+12
| |/ |/| | | | | test_failover_integration
* | Just encode to bytes if it isn't bytes.John Anderson2015-01-241-6/+10
| |
* | Alert if the topic is not sent as bytesJohn Anderson2015-01-231-0/+11
|/
* Add 0.8.2.0 to some kafka_version testsDana Powers2015-01-142-3/+3
|
* Change ZookeeperFixture wait_for regex to support newer zk version used with ↵Dana Powers2015-01-141-1/+1
| | | | 0.8.2.0
* Fix KafkaFixture child stdout / stderr captureDana Powers2015-01-141-2/+2
|
* Merge pull request #289 from alexcb/broker-error-class-refactoringDana Powers2015-01-121-3/+2
|\ | | | | Use reflection to avoid multiple errno definitions
| * Use reflection to avoid multiple errno definitionsAlex Couture-Beil2015-01-101-3/+2
| |
* | Updated unittests to explicitly set random_start valueAlex Couture-Beil2015-01-091-15/+21
|/
* Make TIMEOUT_MS configurable in test_kafka_consumer__blockingDana Powers2014-12-151-4/+5
|
* Merge conflict w/ assertEqual (assertEquals deprecated)Dana Powers2014-12-157-50/+52
|
* Fix task_done checks when no previous commit exists; add testDana Powers2014-12-151-0/+43
|
* Move KafkaConsumer to kafka.consumer.kafka module; make available for import ↵Dana Powers2014-12-152-4/+2
| | | | from kafka at top-level
* Add a few basic KafkaConsumer testsDana Powers2014-12-152-13/+83
|
* fix pending methodNickolai Novik2014-12-151-2/+14
|
* Fixed TestKafkaProducerIntegrationLou Marvin Caraig2014-11-262-17/+29
|
* Merge pull request #233 from dpkp/str_join_speedupMark Roberts2014-09-112-18/+20
|\ | | | | Improve string concatenation performance on pypy and python 3
| * Use b''.join([]) instead of += to speedup codeDana Powers2014-09-102-18/+20
| |
* | Merge pull request #232 from dpkp/directory_layoutDana Powers2014-09-103-3/+3
|\ \ | |/ |/| Separate Consumer/Producer/Partitioner modules
| * Separate consumers/producers/partitionersDana Powers2014-09-103-3/+3
| |
* | Fixup test_context.py unittest importDana Powers2014-09-101-2/+2
| |
* | Merge pull request #217 from locationlabs/transactionDana Powers2014-09-101-0/+117
|\ \ | |/ |/| Commit/rollback consumer offsets via context manager
| * Rename KafkaTransaction to OffsetCommitContext for clarity.Jesse Myers2014-09-031-20/+20
| |
| * Add transaction context manager.Jesse Myers2014-08-301-0/+117
| |
* | Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-083-121/+255
|\ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * | Add client unit tests for has_metadata_for_topic and ensure_topic_existsDana Powers2014-09-011-1/+63
| | |
| * | Add test for sending produce request to unknown topic w/o auto-creationDana Powers2014-09-011-0/+25
| | |
| * | Use standard exceptions in client._get_leader_for_partition()Dana Powers2014-09-013-18/+20
| | | | | | | | | | | | | | | | | | - drop custom PartitionUnavailable exception - raise UnknownTopicOrPartitionError or LeaderNotAvailableError - add tests for exception raises
View Lorry Controller Status