summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
* Fix typoJeff Widman2017-07-011-1/+1
|
* Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return ↵Dana Powers2017-06-181-3/+0
| | | | more data than 0.10
* Increase max_buffer_size for test_large_messagesDana Powers2017-06-181-2/+8
|
* Fix fetch_max_bytes=1 consumer integration testDana Powers2017-06-181-10/+10
|
* Use fixture hostname (dont assume localhost)Dana Powers2017-06-182-2/+2
|
* Timeout idle connections via connections_max_idle_ms (#1068)Dana Powers2017-04-101-2/+36
|
* Avoid multiple connection attempts when refreshing metadata (#1067)Dana Powers2017-04-051-14/+25
|
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-142-4/+6
|
* Alter test skips: python-lz4 works on python26, but not pypyDana Powers2017-03-143-7/+14
|
* Avoid re-encoding for message crc check (#1027)Dana Powers2017-03-131-0/+24
|
* Return copy of consumer subscription set (#1029)Dana Powers2017-03-131-0/+8
|
* 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
|
View Lorry Controller Status