summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
* Increase some integration test timeouts (#1374)Dana Powers2018-02-084-10/+24
|
* Avoid consuming duplicate compressed messages from mid-batch (#1367)Dana Powers2018-02-051-0/+40
|
* KAFKA-3949: Avoid race condition when subscription changes during rebalance ↵Dana Powers2018-02-021-37/+21
| | | | (#1364)
* Use 0.11.0.2 kafka broker for integration testing (#1357)Dana Powers2018-01-251-1/+1
|
* Minor test cleanups (#1343)Dana Powers2018-01-123-2/+5
|
* Honor reconnect_backoff in conn.connect() (#1342)Dana Powers2018-01-111-0/+2
| | | * Honor reconnect_backoff in conn.connect()
* Fix coordinator join_future race condition (#1338)Dana Powers2018-01-111-0/+13
| | | * Fix race condition in coordinator join_future handling
* 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
View Lorry Controller Status