summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* Dump fixture logs on failureDana Powers2016-08-041-0/+2
* Try to bind to a new port on fixture failure retriesDana Powers2016-08-041-29/+21
* Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ...Dana Powers2016-08-041-1/+6
* Instrument metrics in BrokerConnectionDana Powers2016-08-041-0/+2
* Treat metric_group_prefix as config in KafkaConsumerDana Powers2016-08-042-5/+4
* Always absolute_importabsolute_importDana Powers2016-08-024-0/+8
* Move kafka.selectors34 to kafka.vendor.selectors34Dana Powers2016-08-011-1/+1
* Always encode size with MessageSet (#771)Dana Powers2016-07-171-2/+2
* Catch select errors while capturing test fixture logsDana Powers2016-07-171-1/+7
* Delete KafkaConnection class (#769)Dana Powers2016-07-171-210/+0
* KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)Dana Powers2016-07-171-5/+0
* KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)Dana Powers2016-07-171-1/+1
* Merge pull request #762 from dpkp/metadata_v1Dana Powers2016-07-162-28/+37
|\
| * Add rack to BrokerMetadata - it is always None when using MetadataRequest v0Dana Powers2016-07-162-28/+37
* | Add initial producer-sender metricsDana Powers2016-07-161-5/+11
|/
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-165-108/+65
* Include zk-offset configuration in coordinator unit testsDana Powers2016-07-161-2/+6
* Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)Dana Powers2016-07-161-3/+2
* Test MessageSetBuffer close -- cover double close compression bugDana Powers2016-07-141-0/+70
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-201-2/+100
* Use weakref when registering a producer.close atexit to fix normal gc (#728)Dana Powers2016-06-181-0/+14
* Rearrange connection tests to separate legacy KafkaConnectionDana Powers2016-06-043-78/+74
* Fix regression in MessageSet decoding wrt PartialMessages (#716)Dana Powers2016-06-011-1/+101
* Fix socket leaks in KafkaClient (#696)Dana Powers2016-05-221-3/+6
* Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)Dana Powers2016-05-221-0/+23
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-222-1/+61
* Add some simple message protocol testsmessage_format_v1Dana Powers2016-05-221-0/+146
* Rename legacy protocol testsDana Powers2016-05-221-0/+0
* Improve consumer group test loopDana Powers2016-05-221-13/+13
* * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* ...Paul Cavallaro2016-05-101-1/+18
* 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
View Lorry Controller Status