summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
* Update to 0.11.0.1 for travis test fixture; use as default if unspecified ↵Dana Powers2017-10-081-1/+1
| | | | (#1244)
* Add method to ensure a valid topic name (#1238)Niklas Mollenhauer2017-10-071-0/+25
|
* Fix Fetcher.PartitionRecords to handle fetch_offset in the middle of ↵Dana Powers2017-10-051-1/+24
| | | | compressed messageset (#1239)
* Stop using mutable types for default arg values1212-stop-using-mutable-types-for-default-arg-valuesJeff Widman2017-09-124-4/+4
| | | | | | | | Using mutable types for default args is typically a no-no unless their surprising behavior is being explicitly abused, for an explanation see: http://effbot.org/zone/default-values.htm Fix #1212
* remove beginning/end offsets request version limitLiao Jiayi2017-09-041-6/+0
|
* Drop unused sleep kwarg to poll (#1177)Dana Powers2017-08-151-17/+16
|
* Added unit tests for fetcher's `_reset_offset` and related functions.Taras Voinarovskiy2017-08-072-2/+183
|
* Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵Taras Voinarovskiy2017-08-071-1/+46
| | | | review issues
* Changed retrieve_offsets to allow fetching multiple offsets at onceTaras Voinarovskiy2017-08-071-4/+41
|
* Fix test for older brokersTaras Voinarovskiy2017-08-071-2/+4
|
* Added basic support for offsets_for_times API. Still needs to group by nodes ↵Taras Voinarovskiy2017-08-071-1/+45
| | | | and send in parallel.
* 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
|
View Lorry Controller Status