summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* Add disconnected socket tests for conn.recv()Dana Powers2016-04-251-1/+46
* Rename mocked socket as _socket in test_connDana Powers2016-04-251-18/+16
* Merge pull request #670 from zackdever/predictable-futureDana Powers2016-04-252-1/+4
|\
| * enable errors on callbacks in testing. fix broken test.Zack Dever2016-04-252-1/+4
* | Allow setting host interface in KafkaFixture.instanceDana Powers2016-04-251-2/+4
|/
* More thorough IPv6 support that uses getaddrinfo to resolve namesJames Brown2016-04-244-19/+38
* instrument metrics for fetch requestsZack Dever2016-04-131-1/+2
* Beginnings of metrics instrumentation in kafka consumer.Zack Dever2016-04-131-6/+13
* Basic dictionary reporter in place of the java JMX reporter.Zack Dever2016-04-131-3/+36
* Kafka metrics java port. No reporters or instrumentation.Zack Dever2016-04-131-0/+466
* Attempt to add ssl support to kafka fixturesssl_supportDana Powers2016-04-091-4/+10
* Update conn fixture to check for HANDSHAKE stateDana Powers2016-04-091-1/+2
* Use selectors module in KafkaClientselectorsDana Powers2016-04-091-1/+14
* Add state_change_callback to bootstrap connectionconn_state_callbackDana Powers2016-04-081-2/+8
* Move state logic from KafkaClient._maybe_connect to _conn_state_change as cal...Dana Powers2016-04-081-10/+24
* Split test_ready to test_is_readyDana Powers2016-04-081-34/+21
* Speedup some failover tests w/ shorter SimpleClient timeoutDana Powers2016-04-081-1/+1
* Reduce batch time in producer integration test (speedup test)Dana Powers2016-04-081-2/+5
* Default sleep=True in client.pollDana Powers2016-04-081-4/+4
* Add BrokerConnection.disconnected() method; update testsDana Powers2016-04-082-8/+12
* Cleanup AF_INET import in conn fixturefrench_connectionDana Powers2016-04-071-1/+1
* Consolidate conn fixture definitionsDana Powers2016-04-074-42/+19
* Catch more producer exceptions in failover testsDana Powers2016-04-061-3/+6
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-056-63/+64
* KAFKA-3318: clean up consumer logging and error messagesDana Powers2016-04-051-3/+3
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-0516-58/+51
* Add BrokerConnection.send testsDana Powers2016-04-051-9/+102
* Merge pull request #589 from dpkp/node_not_readyDana Powers2016-04-043-283/+361
|\
| * Improve KafkaClient connect and ready handlingnode_not_readyDana Powers2016-04-041-44/+40
| * Add basic unit test coverage for BrokerConnectionDana Powers2016-04-041-0/+82
| * Move old KafkaConnection tests to test_conn_legacyDana Powers2016-04-041-0/+0
* | Test _maybe_auto_commit_offsets_sync when group_id is NoneDana Powers2016-04-031-19/+35
|/
* Kafka IPv6 Support.Tim Evens2016-03-303-18/+37
* Merge pull request #603 from dpkp/windowsDana Powers2016-03-241-0/+2
|\
| * Skip test that fails on windowswindowsDana Powers2016-03-171-0/+2
* | catch all errors thrown by _get_leader_for_partition in SimpleClientZack Dever2016-03-171-3/+3
* | KAFKA-2698: add paused APIZack Dever2016-03-161-5/+25
|/
* join consumer threads in test_consumer_group cleanupDana Powers2016-03-141-2/+4
* Re-render fixture config in restart loop if necessaryDana Powers2016-03-141-0/+10
* More fixture logging improvementsDana Powers2016-03-144-14/+19
* Fixup test fixtures for pylintDana Powers2016-03-132-1/+11
* Merge pull request #585 from dpkp/truncate_bufferDana Powers2016-03-131-5/+22
|\
| * Reduce end-to-end test to 100 messages; raise produce future exceptions immed...Dana Powers2016-03-131-5/+9
| * Add SimpleBufferPool test to verify reallocated buffers are emptyDana Powers2016-03-131-0/+13
* | Improve Fixture loggingDana Powers2016-03-132-31/+19
|/
* Use producer retries and flush timeout in producer end-to-end testDana Powers2016-03-131-1/+2
* Move logging format config to tox.ini to avoid duplicate log capture in pytes...Dana Powers2016-03-131-2/+0
* Add heartbeat timeout testDana Powers2016-03-121-3/+24
* Add test for unknown coordinator heartbeat taskDana Powers2016-03-121-2/+14
* Add timestamps to basic test loggingDana Powers2016-03-121-1/+2