summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
...
| * Merge branch 'master' into 0.9Zack Dever2015-12-072-10/+8
| |\
| * | Fix tests broken by legacy module moveDana Powers2015-12-041-3/+3
| | |
* | | Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)simpleDana Powers2015-12-301-0/+2
| | |
* | | Retry on FailedPayloadsError from consumer.pending() in failover testsDana Powers2015-12-181-4/+5
| | |
* | | Mock client.ensure_topic_exists in test_producer_sync_fail_on_errorproducer_new_topicDana Powers2015-12-171-10/+11
| | |
* | | 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-105-56/+47
| |/ |/|
* | Use producer.stop() to flush messages in async producer testDana Powers2015-12-051-4/+2
| |
* | Cleanup new producer tests...async_producer_connect_errorsDana Powers2015-12-041-6/+6
|/
* new pylint disables for pylint 1.5.1Zack Dever2015-12-021-1/+1
| | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds.
* Merge pull request #420 from toddpalino/masterDana Powers2015-12-021-1/+29
|\ | | | | Initial support for consumer coordinator
| * Fix misnamed node to nodeId in testtpalino2015-07-021-1/+1
| |
| * Add missing import for ConsumerMetadataResponsetpalino2015-07-011-1/+1
| |
| * Support consumer metadata requeststpalino2015-07-011-0/+28
| | | | | | | | | | | | Support added for ConsumerMetadataRequest and ConsumerMetadataResponse Added consumer-aware request routine for supporting the consumer coordinator Added separate client method for fetching Kafka-committed offsets from the coordinator
* | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requestsDana Powers2015-12-021-0/+17
|\ \ | | | | | | Use unblocking io for broker aware requests
| * | Add tests. Bug fix. Rename socket_conn dict.Enrico Canzonieri2015-11-101-0/+17
| |/
* | Merge pull request #457 from saaros/block-for-number-of-messagesDana Powers2015-12-021-0/+18
|\ \ | | | | | | Consumers get_messages: allow blocking until some messages are received
| * | Consumers get_messages: allow blocking until some messages are receivedOskari Saarenmaa2015-09-181-0/+18
| |/ | | | | | | | | | | | | | | | | Modified MultiProcessConsumer's and SimpleConsumer's `block` argument to allow integer value which defines the number of messages to block for. This allows callers to ask for a high number of messages and block only until some of them are received. Otherwise callers would have to request messages one by one or block for some time.
* | Merge pull request #439 from chrischamberlin/fix-murmurDana Powers2015-12-021-0/+23
|\ \ | | | | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3.
| * | Fix translation of Java murmur2 code, fix byte encoding for Python 3.Chris Chamberlin2015-07-281-0/+23
| |/ | | | | | | | | | | Avoid further type changes when Murmur2Partitioner is passed a byte array. Change leftover-bytes logic to match the Java switch statement, and add tests to verify that partition selection matches Java implementation.
* | Merge pull request #435 from docker-hub/fix-producer-cleanup-logicDana Powers2015-12-021-0/+14
|\ \ | | | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects
| * | Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-241-0/+14
| | | | | | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped objects. added tests
* | | Merge pull request #409 from scrapinghub/feature-allow-null-payloadDana Powers2015-12-022-2/+44
|\ \ \ | |_|/ |/| | Allow null payload for deletion feature
| * | Producer test fix for python3Viktor Shlapakov2015-06-171-1/+1
| | |
| * | Add KeyedProducer test with null payloadsViktor Shlapakov2015-06-171-0/+22
| | |
| * | Add basic keyed producer testsViktor Shlapakov2015-06-171-2/+22
| | |
* | | fix #410 SimpleConsumer cannot seek to an absolute offset.haosdent2015-06-201-0/+14
| |/ |/|
* | Increase timeout and backoff when retrying spawn of test fixturesDana Powers2015-06-111-2/+16
| |
* | Merge pull request #402 from dpkp/kafka_0_8_2_1Dana Powers2015-06-102-6/+6
|\ \ | | | | | | Use kafka 0.8.2.1 in integration tests
| * | Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0Dana Powers2015-06-102-6/+6
| | |
* | | Merge pull request #404 from dpkp/consumer_more_exception_handlingDana Powers2015-06-101-2/+42
|\ \ \ | |/ / |/| | Consumer - handle exceptions in commit() and reset_partition_offset()
| * | (test) SimpleConsumer.reset_partition_offset should not raise exception on ↵Dana Powers2015-06-101-1/+16
| | | | | | | | | | | | failure
| * | (test) Consumer commit() should log errors and return True/False, not raise ↵Dana Powers2015-06-101-0/+24
| | | | | | | | | | | | exceptions
| * | Split consumer test class between Simple and MultiProcessDana Powers2015-06-101-1/+2
| | |
* | | Use at_least=True when counting messages in leader failover testsDana Powers2015-06-101-1/+4
|/ /
* | Retry failed messages in failover integration tests; use module loggerDana Powers2015-06-101-12/+17
| |
* | Remove 1 sec timeout on topic creation in client response ordering testDana Powers2015-06-101-2/+2
| |
* | Add KafkaClient test to show that request / response ordering is brokenDana Powers2015-06-101-1/+31
| |
* | Test failover integration with 3-brokers / replicas / partitionsDana Powers2015-06-091-3/+3
|/
* Reset kafka.conn logger level in tearDownDana Powers2015-06-091-0/+13
|
* Support sync_fail_on_error kwarg in ProducerDana Powers2015-06-091-2/+18
|
* Create a new child thread on each open fixture tryDana Powers2015-06-091-6/+7
|
* Merge pull request #397 from dpkp/test_loggingDana Powers2015-06-095-16/+35
|\ | | | | Test logging
| * Dont try to terminate a child that has already exited in test/service _despawnDana Powers2015-06-081-1/+2
| |
| * Produce messages to both partitions in async producer leader switch testDana Powers2015-06-081-1/+9
| |
| * Reduce blocking times in consumer integration testsDana Powers2015-06-081-14/+14
| |
| * Reduce log chatter in tests (only debug kafka.conn in test_conn)Dana Powers2015-06-082-0/+10
| |
* | Add Unit test for async producer leader change; return ProduceResponse on ↵Dana Powers2015-06-091-10/+56
|/ | | | success
* Import style nits in integration testsDana Powers2015-06-084-7/+10
|
* Add zk to KafkaIntegrationTestCase attributes to fix lint errorDana Powers2015-06-081-0/+1
|
View Lorry Controller Status