summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* Fix tests broken by legacy module moveDana Powers2015-12-041-3/+3
* new pylint disables for pylint 1.5.1Zack Dever2015-12-021-1/+1
* Merge pull request #420 from toddpalino/masterDana Powers2015-12-021-1/+29
|\
| * 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
* | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requestsDana Powers2015-12-021-0/+17
|\ \
| * | 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 receivedOskari Saarenmaa2015-09-181-0/+18
| |/
* | 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.Chris Chamberlin2015-07-281-0/+23
| |/
* | Merge pull request #435 from docker-hub/fix-producer-cleanup-logicDana Powers2015-12-021-0/+14
|\ \
| * | Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-241-0/+14
* | | Merge pull request #409 from scrapinghub/feature-allow-null-payloadDana Powers2015-12-022-2/+44
|\ \ \ | |_|/ |/| |
| * | 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
|\ \
| * | 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
|\ \ \ | |/ / |/| |
| * | (test) SimpleConsumer.reset_partition_offset should not raise exception on fa...Dana Powers2015-06-101-1/+16
| * | (test) Consumer commit() should log errors and return True/False, not raise e...Dana Powers2015-06-101-0/+24
| * | 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
|\
| * 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 suc...Dana Powers2015-06-091-10/+56
|/
* 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
* Dump fixture logs on OffsetResponse error during producer integrationDana Powers2015-06-081-3/+9
* Retry with shorter 5sec timeout when trying to open() fixturesDana Powers2015-06-082-7/+14
* Add unit tests for SimpleConsumer error handlingDana Powers2015-06-081-1/+74
* Merge pull request #380 from dpkp/multiprocess_consumer_partitionsDana Powers2015-06-081-2/+11
|\
| * Support optional partitions kwarg in MultiProcessConsumerDana Powers2015-05-171-2/+11
* | Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-081-10/+10
|\ \
| * | Deprecate KeyedProducer.send in favor of send_messages -- keep interface cons...Dana Powers2015-05-171-10/+10
| |/
* | try to fix uncaught FailedPayloadsErrorreAsOn20102015-06-091-0/+8