summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
...
* 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
| * | load_metadata_for_topics should raise exceptions on explicit topic argsDana Powers2014-09-011-25/+46
| | |
| * | 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
| * | No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableErrorDana Powers2014-09-012-4/+3
| | |
| * | Improve metadata protocol handlingDana Powers2014-09-012-109/+123
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - 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]
* | | Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-0716-299/+334
|\ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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 the multiprocessing tests for python 3Mark Roberts2014-09-031-1/+1
| | | |
| * | | Fix test errors related to mocksMark Roberts2014-09-031-3/+6
| | | |
| * | | Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-036-20/+32
| | | |
| * | | Bytes in self.msg()Bruno Renié2014-09-031-1/+1
| | | |
| * | | More bytes topicsBruno Renié2014-09-032-2/+2
| | | |
| * | | Encode topic directlyBruno Renié2014-09-031-1/+2
| | | |
| * | | Fix bytes interpolationBruno Renié2014-09-031-1/+1
| | | |
| * | | Topic in bytesBruno Renié2014-09-031-1/+1
| | | |
| * | | Fix stderr captureBruno Renié2014-09-031-1/+1
| | | |
| * | | Fix log capture on py3Bruno Renié2014-09-031-1/+1
| | | |
| * | | Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-0311-241/+257
| | | |
| * | | Use base unittest or unittest2 depending on python versionBruno Renié2014-09-0312-29/+37
| |/ /
* | | Cleanup tests: no more import *; remove unusedDana Powers2014-09-049-54/+26
| | |
* | | Another attempt to fix failover test flappingDana Powers2014-09-041-16/+23
| | |
* | | Import cleanups in testsDana Powers2014-09-046-24/+38
| | |
* | | Merge pull request #222 from dpkp/fix_socket_timeout_testMark Roberts2014-09-042-12/+19
|\ \ \ | |/ / |/| | Fix socket timeout test -- mock the side_effect
| * | Fix socket timeout test -- mock the side_effectDana Powers2014-09-012-12/+19
| |/
* | just fixing a silly except formatting mistakeZack Dever2014-08-291-1/+1
|/
* Fixup producer failover tests to avoid consumer message count flapDana Powers2014-08-271-7/+8
| | | | | check message counts via consumer.pending() (OffsetRequest) rather than relying on consumer message iterator (FetchRequest)
* Merge pull request #213 from dpkp/improve_failover_testsDana Powers2014-08-271-45/+67
|\ | | | | | | | | Warn users about async producer Refactor producer failover tests (5x speedup) Skip async producer failover test for now, because it is broken
| * Improve leader failover tests; note that async produce failover is broken -- ↵Dana Powers2014-08-261-45/+67
| | | | | | | | so skip that test for now
* | Add a test for Issue #135 (Spurious ConsumerFetchSizeTooSmall error)Dana Powers2014-08-261-0/+19
|/
* Merge pull request #208 from dpkp/add_pylint_to_tox_iniDana Powers2014-08-266-51/+41
|\ | | | | Use PyLint for static error checking
| * Add pylint to tox.ini; test both kafka and test; default to error-checking ↵Dana Powers2014-08-256-51/+41
| | | | | | | | only; fixup errors; skip kafka/queue.py
* | Add producer unit test (test/test_producer.py); check supported types in ↵Dana Powers2014-08-261-0/+31
|/ | | | send_messages
* Merge pull request #196 from dpkp/reinit_connection_errorDana Powers2014-08-221-22/+117
|\ | | | | Improve KafkaConnection with more tests
| * Add a mock to sock.recv() in the test_conn setUp method. Returns 2 packet ↵Dana Powers2014-08-191-61/+25
| | | | | | | | payloads, then '', then error
View Lorry Controller Status