summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-215-56/+107
|
* Minor Exception cleanupJeff Widman2017-12-123-4/+4
|
* Refactor dns lookup in BrokerConnection (#1312)Dana Powers2017-12-081-0/+25
|
* Change fixture default host to localhost (#1305)Andre Araujo2017-12-051-15/+1
|
* Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239Dana Powers2017-11-161-23/+0
| | | | The change caused a regression documented in issue #1290
* Handle lookup_coordinator send failures (#1279)Dana Powers2017-10-241-0/+8
|
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵Taras Voinarovskyi2017-10-255-6/+315
| | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.
* Add fixture support for upcoming 1.0.0 broker release (#1275)Dana Powers2017-10-231-2/+6
|
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-222-8/+139
| | | | | | | | * Fix timestamp not being passed to RecordMetadata properly * Add more tests for LegacyBatch * Fix producer test for recordmetadata
* Move callback processing from BrokerConnection to KafkaClientpending_completionsDana Powers2017-10-151-1/+2
|
* Merge pull request #1252 from dpkp/legacy_records_refactorTaras Voinarovskyi2017-10-147-180/+236
|\ | | | | Refactor MessageSet and Message into LegacyRecordBatch
| * Fix tests and rebase problemsTaras2017-10-121-95/+27
| |
| * Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-116-85/+209
| | | | | | | | message format
* | KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)Dana Powers2017-10-111-5/+4
|/
* Merge pull request #1245 from dpkp/KAFKA_3977_defer_fetch_parsingTaras Voinarovskyi2017-10-111-16/+300
|\ | | | | KAFKA-3977: defer fetch response parsing and raise exceptions to user
| * More testsKAFKA_3977_defer_fetch_parsingDana Powers2017-10-081-15/+195
| |
| * Add tests for Fetcher.fetched_records and _handle_fetch_responseDana Powers2017-10-071-14/+118
| |
* | 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
|
View Lorry Controller Status