| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Vendor `six` consistently | Jeff Widman | 2018-10-22 | 10 | -23/+23 |
| | | | | | Use vendored `six`, and also `six.moves.range` rather than `xrange` | ||||
| * | Fix typo in file name | Jeff Widman | 2018-10-22 | 1 | -0/+0 |
| | | |||||
| * | Support produce with Kafka record headers | Heikki Nousiainen | 2018-09-27 | 1 | -1/+9 |
| | | |||||
| * | Expose record headers in ConsumerRecords | Heikki Nousiainen | 2018-09-27 | 1 | -3/+3 |
| | | |||||
| * | Add positive tests for headers in record encode/decode | Heikki Nousiainen | 2018-09-27 | 2 | -3/+18 |
| | | |||||
| * | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 6 | -13/+14 |
| | | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
| * | Ignore MetadataResponses with empty broker list (#1506) | Dana Powers | 2018-05-26 | 1 | -0/+22 |
| | | |||||
| * | Stop shadowing `ConnectionError` | Jeff Widman | 2018-05-23 | 3 | -6/+6 |
| | | | | | | | | | | | In Python3, `ConnectionError` is a native exception. So rename our custom one to `KafkaConnectionError` to prevent accidentally shadowing the native one. Note that there are still valid uses of `ConnectionError` in this code. They already expect a native Python3 `ConnectionError`, and also already handle the Python2 compatibility issues. | ||||
| * | Skip flakey SimpleProducer test | Dana Powers | 2018-04-18 | 1 | -0/+1 |
| | | |||||
| * | Add codec validators to record parser and builder for all formats (#1447) | Taras | 2018-04-18 | 5 | -5/+96 |
| | | |||||
| * | Fix MemoryRecord bugs re error handling and add test coverage (#1448) | Taras | 2018-04-18 | 1 | -1/+68 |
| | | |||||
| * | Change SimpleProducer to use async_send (async is reserved in py37) (#1454) | Dana Powers | 2018-03-23 | 3 | -13/+13 |
| | | |||||
| * | Fix skipped integration tests if KAFKA_VERSION unset (#1453) | Dana Powers | 2018-03-22 | 2 | -0/+9 |
| | | |||||
| * | Connect with sockaddrs to support non-zero ipv6 scope ids (#1433) | Dana Powers | 2018-03-09 | 1 | -15/+12 |
| | | |||||
| * | Add BrokerConnection.connect_blocking() (#1411) | Dana Powers | 2018-03-09 | 2 | -3/+6 |
| | | |||||
| * | 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 | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |