summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
* Avoid re-encoding for message crc checkfaster_validate_crcDana Powers2017-03-131-0/+24
|
* Fix kwarg handing in kafka.protocol.struct.Struct (#1025)Dana Powers2017-03-091-1/+15
|
* Fix integration test that requires consumer groupDana Powers2017-03-071-1/+4
|
* Disable default consumer group (#1016)Dana Powers2017-03-061-0/+2
|
* Added `max_bytes` option and FetchRequest_v3 usage. (#962)Taras Voinarovskyi2017-03-062-1/+48
| | | | * Added `max_bytes` option and FetchRequest_v3 usage. * Add checks for versions above 0.10 based on ApiVersionResponse
* Remove dead code (#967)Jeff Widman2017-02-281-46/+0
|
* Fail-fast on timeout constraint violations during KafkaConsumer creation (#986)Harel Ben-Attia2017-02-281-0/+8
|
* Drop bad disconnect test -- just use the mocked-socket test (#982)Dana Powers2017-02-241-27/+1
|
* PEP-8: Spacing & removed unused imports (#899)Jeff Widman2017-02-091-4/+2
|
* Spelling and grammar changes (#923)melissacrawford3962017-01-112-2/+2
|
* Update pytest fixtures to new yield syntax (#919)Jeff Widman2017-01-112-10/+6
|
* Add metadata update to pattern subscribing (#915)Dmitry Lazurkin2016-12-271-2/+26
|
* When hostname lookup is necessary, do every connect (#812)Evan Bender2016-11-201-0/+28
| | | | | Fixes a bug where lookup was done only once for the whole life of the process -- if a broker's IP changed, client couldn't reconnect.
* Fix typosJeff Widman2016-11-143-3/+3
|
* Fix murmur2 bug handling python2 bytes that do not ascii encode (#815)Dana Powers2016-10-221-15/+9
| | | | | | * Add test for murmur2 py2 bytes bug * Fix murmur2 handling of python2 bytes * Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported * Make DefaultPartitioner importable from kafka.partitioner
* KAFKA-3007: KafkaConsumer max_poll_records (#831)Dana Powers2016-09-283-22/+3
|
* Update Partitioners for use with KafkaProducer (#827)barrotsteindev2016-09-281-0/+33
|
* 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
| | | | group test (#795)
* 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
|\ | | | | Use Metadata Request/Response v1 with 0.10+ brokers
| * 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
| | | | * Dont wait for group join to enable AutoCommitTask if broker version < 0.9 * For zookeeper offset storage, set a "coordinator" with least_loaded_node
* 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
| | | | * Use weakref when registering a producer.close atexit to fix normal gc * Test that del(producer) terminates async thread
* 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
| | | | | * Cleanup wakeup socketpair on close to avoid leak in KafkaClient * Cleanup unneeded bootstrap connection to avoid leak in KafkaClient * Dont warn on socket disconnections caused by KafkaClient.close()
* Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)Dana Powers2016-05-221-0/+23
| | | | | | * LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility * lz4f does not support easy incremental decompression - raise RuntimeError * Update lz4 codec tests
* 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
| | | | | [Legacy Protocol] Update legacy protocol to handle compressed messages * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages
* 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
|\ | | | | Consistent error handling in future call/errbacks + better test failures
View Lorry Controller Status