summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
* Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ↵Dana Powers2018-03-091-9/+20
| | | | for current lookups (#1422)
* Fix BrokerConnection.connection_delay() to return milliseconds (#1414)Dana Powers2018-03-081-0/+9
|
* Close KafkaConsumer instances during tests (#1410)Dana Powers2018-03-083-1/+11
|
* Fix KafkaConsumer compacted offset handling (#1397)Dana Powers2018-02-261-2/+19
|
* Fixes racing condition when message is sent to broker before topic logs are ↵Andre Araujo2018-02-211-3/+19
| | | | created
* Introduce new fixtures to prepare for migration to pytest.Andre Araujo2018-02-217-157/+458
| | | | | | | This commits adds new pytest fixtures in prepation for the migration of unittest.TestCases to pytest test cases. The handling of temporary dir creation was also changed so that we can use the pytest tmpdir fixture after the migration.
* Use hardware accelerated CRC32C function if available (#1389)Taras Voinarovskyi2018-02-211-2/+3
| | | | | | * Use hardware accelerated CRC32C function if available * Add doc notice of optional `crc32c` package
* 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
|