| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Do not validate api_version against known versionsany_api_version | Dana Powers | 2018-03-09 | 3 | -20/+3 |
| | | |||||
| * | 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 | ||||
| * | Use 0.11.0.2 kafka broker for integration testing (#1357) | Dana Powers | 2018-01-25 | 7 | -4/+192 |
| | | |||||
| * | Fix for Python 3 byte string handling in SASL auth (#1353) | Christophe Lecointe | 2018-01-24 | 2 | -2/+4 |
| | | |||||
| * | Remove assertion with side effect (#1348) | Buğra Gedik | 2018-01-23 | 1 | -2/+2 |
| | | |||||
| * | fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352) | C.YAO | 2018-01-23 | 1 | -1/+1 |
| | | |||||
| * | Name heartbeat thread with group_id; use backoff when polling (#1345) | Dana Powers | 2018-01-16 | 1 | -1/+1 |
| | | |||||
| * | Minor test cleanups (#1343) | Dana Powers | 2018-01-12 | 3 | -2/+5 |
| | | |||||
| * | Avoid KeyError when filtering fetchable partitions (#1344) | Dana Powers | 2018-01-12 | 1 | -2/+2 |
| | | | | | * Avoid KeyError when filtering fetchable partitions | ||||
| * | Honor reconnect_backoff in conn.connect() (#1342) | Dana Powers | 2018-01-11 | 2 | -1/+3 |
| | | | | * Honor reconnect_backoff in conn.connect() | ||||
| * | Fix coordinator join_future race condition (#1338) | Dana Powers | 2018-01-11 | 2 | -4/+21 |
| | | | | * Fix race condition in coordinator join_future handling | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |