summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* Connect with sockaddrs to support non-zero ipv6 scope idsipv6_scope_idDana Powers2018-03-091-15/+12
* Add BrokerConnection.connect_blocking() (#1411)Dana Powers2018-03-092-3/+6
* Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ...Dana Powers2018-03-091-9/+20
* 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 c...Andre Araujo2018-02-211-3/+19
* Introduce new fixtures to prepare for migration to pytest.Andre Araujo2018-02-217-157/+458
* Use hardware accelerated CRC32C function if available (#1389)Taras Voinarovskyi2018-02-211-2/+3
* 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
* 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
* Fix coordinator join_future race condition (#1338)Dana Powers2018-01-111-0/+13
* 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
* 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
* 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
* 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
|\
| * Fix tests and rebase problemsTaras2017-10-121-95/+27
| * Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...Taras2017-10-116-85/+209
* | 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
|\
| * 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 (#1...Dana Powers2017-10-081-1/+1
|/
* 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 compress...Dana Powers2017-10-051-1/+24
* Stop using mutable types for default arg values1212-stop-using-mutable-types-for-default-arg-valuesJeff Widman2017-09-124-4/+4
* 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 revie...Taras Voinarovskiy2017-08-071-1/+46
* 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
* 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
* 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
View Lorry Controller Status