| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Patch Release 1.4.21.4.2 | Dana Powers | 2018-03-10 | 3 | -4/+10 | |
| | | ||||||
| * | KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to ↵ | Dana Powers | 2018-03-10 | 1 | -0/+4 | |
| | | | | | 0 (#1439) | |||||
| * | Add kafka 1.0.1 release to test fixtures (#1437) | Dana Powers | 2018-03-10 | 5 | -2/+190 | |
| | | ||||||
| * | Remove old CommitFailed error message from coordinator (#1436) | Dana Powers | 2018-03-10 | 1 | -11/+1 | |
| | | ||||||
| * | Update changelog with unreleased 1.4.2 notes | Dana Powers | 2018-03-10 | 2 | -0/+96 | |
| | | ||||||
| * | Validate that serializers generate bytes-like (or None) data (#1420) | Dana Powers | 2018-03-10 | 1 | -2/+3 | |
| | | ||||||
| * | Do not validate api_version against known versions (#1434) | Dana Powers | 2018-03-10 | 3 | -20/+3 | |
| | | ||||||
| * | Connect with sockaddrs to support non-zero ipv6 scope ids (#1433) | Dana Powers | 2018-03-09 | 2 | -28/+22 | |
| | | ||||||
| * | Re-enable logging during broker version check (#1430) | Dana Powers | 2018-03-09 | 1 | -12/+1 | |
| | | ||||||
| * | Connection logging cleanups (#1432) | Dana Powers | 2018-03-09 | 1 | -4/+5 | |
| | | ||||||
| * | Add BrokerConnection.connect_blocking() (#1411) | Dana Powers | 2018-03-09 | 5 | -36/+55 | |
| | | ||||||
| * | Short-circuit BrokerConnection.close() if already disconnected (#1424) | Dana Powers | 2018-03-09 | 1 | -3/+6 | |
| | | ||||||
| * | Only increase reconnect backoff if all addrinfos have been tried (#1423) | Dana Powers | 2018-03-09 | 1 | -1/+4 | |
| | | ||||||
| * | Support alternative lz4framed (#1395) | everpcpc | 2018-03-09 | 1 | -0/+11 | |
| | | ||||||
| * | Close leaked selector in version check (#1425) | Dana Powers | 2018-03-09 | 1 | -0/+1 | |
| | | ||||||
| * | Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ↵ | Dana Powers | 2018-03-09 | 2 | -24/+45 | |
| | | | | | for current lookups (#1422) | |||||
| * | Avoid tight poll loop in consumer when brokers are down (#1415) | Dana Powers | 2018-03-08 | 1 | -1/+1 | |
| | | ||||||
| * | Fix BrokerConnection.connection_delay() to return milliseconds (#1414) | Dana Powers | 2018-03-08 | 2 | -2/+18 | |
| | | ||||||
| * | Close KafkaConsumer instances during tests (#1410) | Dana Powers | 2018-03-08 | 3 | -1/+11 | |
| | | ||||||
| * | Use local copies in Fetcher._fetchable_partitions to avoid mutation errors ↵ | Dana Powers | 2018-03-07 | 1 | -3/+6 | |
| | | | | | (#1400) | |||||
| * | Fix error var name in _unpack (#1403) | j2gg0s | 2018-03-05 | 1 | -1/+1 | |
| | | | | Change-Id: I6527da4b70ebec9e08fa50aca9eba717b8361f19 | |||||
| * | Validate max_records in KafkaConsumer.poll (#1398) | Dana Powers | 2018-02-27 | 1 | -0/+2 | |
| | | ||||||
| * | Fix KafkaConsumer compacted offset handling (#1397) | Dana Powers | 2018-02-26 | 2 | -10/+28 | |
| | | ||||||
| * | Fix byte size estimation with kafka producer (#1393) | Blake Embrey | 2018-02-24 | 1 | -1/+1 | |
| | | ||||||
| * | 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 | 9 | -157/+460 | |
| | | | | | | | | 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. | |||||
| * | Check timeout type in KafkaClient constructor | Andre Araujo | 2018-02-21 | 1 | -0/+2 | |
| | | | | | | | | | | | If a future was passed as the only positional parameter it would be assigned to the "timeout_ms" parameter erroneously. This mistake would not raise any exception but would lead to odd behaviour later, what could make it extremely difficult to troubleshoot. Adding a type check ensures that an exception is raise earlier to notify the user about the problem. | |||||
| * | Update string representation of SimpleClient | Andre Araujo | 2018-02-21 | 1 | -1/+1 | |
| | | ||||||
| * | Use hardware accelerated CRC32C function if available (#1389) | Taras Voinarovskyi | 2018-02-21 | 4 | -5/+28 | |
| | | | | | | | * Use hardware accelerated CRC32C function if available * Add doc notice of optional `crc32c` package | |||||
| * | Correctly respect timeouts in consumer poll interface (#1384) | Braedon Vickers | 2018-02-21 | 1 | -1/+1 | |
| | | ||||||
| * | Fix response schema | Alex Eftimie | 2018-02-20 | 1 | -1/+2 | |
| | | ||||||
| * | Add Admin CreatePartitions API call | Alex Eftimie | 2018-02-20 | 2 | -1/+32 | |
| | | ||||||
| * | Removed pytest-catchlog dependency | Andre Araujo | 2018-02-12 | 1 | -1/+0 | |
| | | | | | | | | | | No longer necessary since pytest-catchlog has been merged into pytest's core. This commit addresses the following warning in pytest output: pytest-catchlog plugin has been merged into the core, please remove it from your requirements. Fixes #1379 | |||||
| * | Bump version for development | Dana Powers | 2018-02-10 | 1 | -1/+1 | |
| | | ||||||
| * | Patch Release 1.4.1 (#1376)1.4.1 | Dana Powers | 2018-02-09 | 3 | -1/+21 | |
| | | ||||||
| * | Fix consumer poll stuck error when no available partition (#1375) | Yu Kou | 2018-02-08 | 1 | -1/+1 | |
| | | ||||||
| * | Increase some integration test timeouts (#1374) | Dana Powers | 2018-02-08 | 5 | -11/+26 | |
| | | ||||||
| * | Use raw in case string overriden (#1373) | Jeff Widman | 2018-02-08 | 1 | -2/+2 | |
| | | ||||||
| * | Fix pending completion IndexError bug caused by multiple threads (#1372) | Dana Powers | 2018-02-08 | 1 | -2/+8 | |
| | | ||||||
| * | Bump version for development of next release | Dana Powers | 2018-02-07 | 1 | -1/+1 | |
| | | ||||||
| * | Release 1.4.01.4.0 | Dana Powers | 2018-02-07 | 6 | -7/+189 | |
| | | ||||||
| * | pylint 1.8.2 (#1369) | Dana Powers | 2018-02-06 | 2 | -2/+2 | |
| | | ||||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 43 | -144/+144 | |
| | | ||||||
| * | Add Request/Response structs for kafka broker 1.0.0 | Dana Powers | 2018-02-06 | 6 | -36/+167 | |
| | | ||||||
| * | Avoid consuming duplicate compressed messages from mid-batch (#1367) | Dana Powers | 2018-02-05 | 2 | -2/+51 | |
| | | ||||||
| * | KAFKA-3949: Avoid race condition when subscription changes during rebalance ↵ | Dana Powers | 2018-02-02 | 7 | -109/+128 | |
| | | | | | (#1364) | |||||
| * | Add kafka 1.0.0 to travis integration tests | Dana Powers | 2018-02-01 | 1 | -0/+1 | |
| | | ||||||
| * | Bump `lz4` in `requirements-dev.txt` (#1359) | Jeff Widman | 2018-01-31 | 1 | -1/+1 | |
| | | ||||||
| * | Use latest pytest 3.4.0, but drop pytest-sugar due to incompatibility (#1361) | Dana Powers | 2018-01-31 | 2 | -3/+1 | |
| | | ||||||
| * | Stop pinning lz4 | Jeff Widman | 2018-01-26 | 1 | -1/+1 | |
| | | | | | | Opening a PR to check if tests pass with the new version. If so, we'll want to bump `requirements-dev.txt` as well. Many thanks to @jonathanunderwood for his diligent work here: https://github.com/dpkp/kafka-python/issues/1021#issuecomment-359161985 | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |