summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* Stop shadowing `ConnectionError`Stop-shadowing-native-python-ConnectionError-exceptionJeff Widman2018-05-103-6/+6
* Skip flakey SimpleProducer testDana Powers2018-04-181-0/+1
* Add codec validators to record parser and builder for all formats (#1447)Taras2018-04-185-5/+96
* Fix MemoryRecord bugs re error handling and add test coverage (#1448)Taras2018-04-181-1/+68
* Change SimpleProducer to use async_send (async is reserved in py37) (#1454)Dana Powers2018-03-233-13/+13
* Fix skipped integration tests if KAFKA_VERSION unset (#1453)Dana Powers2018-03-222-0/+9
* Connect with sockaddrs to support non-zero ipv6 scope ids (#1433)Dana 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
View Lorry Controller Status