summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* Fix KafkaClient->SimpleClient references0.9Dana Powers2016-01-075-44/+44
* Drop request_timeout_ms override in consumer group testDana Powers2016-01-041-2/+1
* Dont use consumer_timeout_ms in simple kafka_consumer testDana Powers2016-01-041-2/+1
* Dont use consumer_timeout_ms in kafka blocking testDana Powers2016-01-031-7/+4
* Fast heartbeats during consumer group testsDana Powers2016-01-031-0/+1
* Import queue from six.movesDana Powers2016-01-031-10/+3
* Add pytests for KafkaConsumer group assignmentsDana Powers2016-01-031-0/+170
* Use parameterized pytests in test_client_async; add pytest-mocker pluginDana Powers2016-01-031-70/+94
* Use 2-second KafkaClient timeout in failover testsDana Powers2016-01-031-1/+1
* Update consumer integration tests to use new (group) KafkaConsumerDana Powers2016-01-031-29/+31
* bootstrap_servers no longer required in KafkaConsumer (localhost default)Dana Powers2016-01-031-4/+0
* Disable pylint errors for py2/py3 compatibility workaroundsDana Powers2016-01-011-1/+1
* Skeleton tests for async kafka clientDana Powers2016-01-011-0/+103
* Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)Dana Powers2015-12-301-0/+2
* Catch and retry on RequestTimedOutError in producer failover testDana Powers2015-12-291-2/+4
* Rename TopicAndPartition -> TopicPartitionDana Powers2015-12-285-19/+19
* Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-171-35/+47
* Drop bytes encoding of consumer group in consumer integration testDana Powers2015-12-101-1/+1
* Remove bytes encoding for topic name in producer integration testDana Powers2015-12-101-1/+1
* Move Request / Response logging from KafkaClient to BrokerConnectionDana Powers2015-12-102-21/+0
* pylint fixesDana Powers2015-12-102-1/+2
* Remove KafkaProtocol._decode_messageDana Powers2015-12-101-0/+2
* Fix consumer integration test that assumed a single brokerDana Powers2015-12-101-4/+6
* Fix zk_chroot in consumer integration kafka fixturesDana Powers2015-12-101-2/+3
* Drop kafka_bytestringDana Powers2015-12-106-33/+28
* Configure consumer group in consumer_integration testsDana Powers2015-12-101-3/+13
* Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-103-7/+7
* Fix test_consumer generator/list mock, reenable testsDana Powers2015-12-101-5/+2
* Update kafka.common imports to Payloads namedtuples in test_protocolDana Powers2015-12-091-22/+24
* Default consumer integration tests should not use offset commitsDana Powers2015-12-091-2/+3
* Skip protocol tests for now -- need updatingDana Powers2015-12-091-0/+20
* Update to Payload namedtuples in consumer testsDana Powers2015-12-091-4/+4
* Skip consumer tests that cause iterator errors -- needs investigationDana Powers2015-12-091-0/+3
* Update client tests for new protocol usageDana Powers2015-12-091-74/+61
* Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-095-19/+19
* Merge branch 'master' into 0.9Zack Dever2015-12-072-10/+8
|\
| * 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
* | 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
| |/
View Lorry Controller Status