Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ↵ | Dana Powers | 2018-03-09 | 1 | -9/+20 |
| | | | | for current lookups (#1422) | ||||
* | Fix BrokerConnection.connection_delay() to return milliseconds (#1414) | Dana Powers | 2018-03-08 | 1 | -0/+9 |
| | |||||
* | Close KafkaConsumer instances during tests (#1410) | Dana Powers | 2018-03-08 | 3 | -1/+11 |
| | |||||
* | Fix KafkaConsumer compacted offset handling (#1397) | Dana Powers | 2018-02-26 | 1 | -2/+19 |
| | |||||
* | Fixes racing condition when message is sent to broker before topic logs are ↵ | Andre Araujo | 2018-02-21 | 1 | -3/+19 |
| | | | | created | ||||
* | Introduce new fixtures to prepare for migration to pytest. | Andre Araujo | 2018-02-21 | 7 | -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 Voinarovskyi | 2018-02-21 | 1 | -2/+3 |
| | | | | | | * Use hardware accelerated CRC32C function if available * Add doc notice of optional `crc32c` package | ||||
* | Increase some integration test timeouts (#1374) | Dana Powers | 2018-02-08 | 4 | -10/+24 |
| | |||||
* | Avoid consuming duplicate compressed messages from mid-batch (#1367) | Dana Powers | 2018-02-05 | 1 | -0/+40 |
| | |||||
* | KAFKA-3949: Avoid race condition when subscription changes during rebalance ↵ | Dana Powers | 2018-02-02 | 1 | -37/+21 |
| | | | | (#1364) | ||||
* | Use 0.11.0.2 kafka broker for integration testing (#1357) | Dana Powers | 2018-01-25 | 1 | -1/+1 |
| | |||||
* | Minor test cleanups (#1343) | Dana Powers | 2018-01-12 | 3 | -2/+5 |
| | |||||
* | Honor reconnect_backoff in conn.connect() (#1342) | Dana Powers | 2018-01-11 | 1 | -0/+2 |
| | | | * Honor reconnect_backoff in conn.connect() | ||||
* | Fix coordinator join_future race condition (#1338) | Dana Powers | 2018-01-11 | 1 | -0/+13 |
| | | | * Fix race condition in coordinator join_future handling | ||||
* | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 5 | -56/+107 |
| | |||||
* | Minor Exception cleanup | Jeff Widman | 2017-12-12 | 3 | -4/+4 |
| | |||||
* | Refactor dns lookup in BrokerConnection (#1312) | Dana Powers | 2017-12-08 | 1 | -0/+25 |
| | |||||
* | Change fixture default host to localhost (#1305) | Andre Araujo | 2017-12-05 | 1 | -15/+1 |
| | |||||
* | Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239 | Dana Powers | 2017-11-16 | 1 | -23/+0 |
| | | | | The change caused a regression documented in issue #1290 | ||||
* | Handle lookup_coordinator send failures (#1279) | Dana Powers | 2017-10-24 | 1 | -0/+8 |
| | |||||
* | Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵ | Taras Voinarovskyi | 2017-10-25 | 5 | -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 Powers | 2017-10-23 | 1 | -2/+6 |
| | |||||
* | Fix timestamp not passed to RecordMetadata (#1273) | Taras Voinarovskyi | 2017-10-22 | 2 | -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_completions | Dana Powers | 2017-10-15 | 1 | -1/+2 |
| | |||||
* | Merge pull request #1252 from dpkp/legacy_records_refactor | Taras Voinarovskyi | 2017-10-14 | 7 | -180/+236 |
|\ | | | | | Refactor MessageSet and Message into LegacyRecordBatch | ||||
| * | Fix tests and rebase problems | Taras | 2017-10-12 | 1 | -95/+27 |
| | | |||||
| * | Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵ | Taras | 2017-10-11 | 6 | -85/+209 |
| | | | | | | | | message format | ||||
* | | KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254) | Dana Powers | 2017-10-11 | 1 | -5/+4 |
|/ | |||||
* | Merge pull request #1245 from dpkp/KAFKA_3977_defer_fetch_parsing | Taras Voinarovskyi | 2017-10-11 | 1 | -16/+300 |
|\ | | | | | KAFKA-3977: defer fetch response parsing and raise exceptions to user | ||||
| * | More testsKAFKA_3977_defer_fetch_parsing | Dana Powers | 2017-10-08 | 1 | -15/+195 |
| | | |||||
| * | Add tests for Fetcher.fetched_records and _handle_fetch_response | Dana Powers | 2017-10-07 | 1 | -14/+118 |
| | | |||||
* | | Update to 0.11.0.1 for travis test fixture; use as default if unspecified ↵ | Dana Powers | 2017-10-08 | 1 | -1/+1 |
|/ | | | | (#1244) | ||||
* | Add method to ensure a valid topic name (#1238) | Niklas Mollenhauer | 2017-10-07 | 1 | -0/+25 |
| | |||||
* | Fix Fetcher.PartitionRecords to handle fetch_offset in the middle of ↵ | Dana Powers | 2017-10-05 | 1 | -1/+24 |
| | | | | compressed messageset (#1239) | ||||
* | Stop using mutable types for default arg values1212-stop-using-mutable-types-for-default-arg-values | Jeff Widman | 2017-09-12 | 4 | -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 limit | Liao Jiayi | 2017-09-04 | 1 | -6/+0 |
| | |||||
* | Drop unused sleep kwarg to poll (#1177) | Dana Powers | 2017-08-15 | 1 | -17/+16 |
| | |||||
* | Added unit tests for fetcher's `_reset_offset` and related functions. | Taras Voinarovskiy | 2017-08-07 | 2 | -2/+183 |
| | |||||
* | Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵ | Taras Voinarovskiy | 2017-08-07 | 1 | -1/+46 |
| | | | | review issues | ||||
* | Changed retrieve_offsets to allow fetching multiple offsets at once | Taras Voinarovskiy | 2017-08-07 | 1 | -4/+41 |
| | |||||
* | Fix test for older brokers | Taras Voinarovskiy | 2017-08-07 | 1 | -2/+4 |
| | |||||
* | Added basic support for offsets_for_times API. Still needs to group by nodes ↵ | Taras Voinarovskiy | 2017-08-07 | 1 | -1/+45 |
| | | | | and send in parallel. | ||||
* | Fix typo | Jeff Widman | 2017-07-01 | 1 | -1/+1 |
| | |||||
* | Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return ↵ | Dana Powers | 2017-06-18 | 1 | -3/+0 |
| | | | | more data than 0.10 | ||||
* | Increase max_buffer_size for test_large_messages | Dana Powers | 2017-06-18 | 1 | -2/+8 |
| | |||||
* | Fix fetch_max_bytes=1 consumer integration test | Dana Powers | 2017-06-18 | 1 | -10/+10 |
| | |||||
* | Use fixture hostname (dont assume localhost) | Dana Powers | 2017-06-18 | 2 | -2/+2 |
| | |||||
* | Timeout idle connections via connections_max_idle_ms (#1068) | Dana Powers | 2017-04-10 | 1 | -2/+36 |
| | |||||
* | Avoid multiple connection attempts when refreshing metadata (#1067) | Dana Powers | 2017-04-05 | 1 | -14/+25 |
| | |||||
* | Derive all api classes from Request / Response base classes (#1030) | Dana Powers | 2017-03-14 | 2 | -4/+6 |
| |