| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Stop shadowing `ConnectionError`Stop-shadowing-native-python-ConnectionError-exception | Jeff Widman | 2018-05-10 | 8 | -31/+30 |
| | | | | | | | | | | | 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. | ||||
| * | Minor doc capitalization cleanup | Jeff Widman | 2018-04-24 | 1 | -15/+15 |
| | | |||||
| * | Force lz4 to disable Kafka-unsupported block linking when encoding (#1476) | Michael P. Nitowski | 2018-04-18 | 1 | -1/+13 |
| | | |||||
| * | Skip flakey SimpleProducer test | Dana Powers | 2018-04-18 | 1 | -0/+1 |
| | | |||||
| * | Added AlterConfigs and DescribeConfigs apis (#1472) | Stephen SORRIAUX | 2018-04-18 | 1 | -1/+96 |
| | | |||||
| * | Add codec validators to record parser and builder for all formats (#1447) | Taras | 2018-04-18 | 9 | -15/+136 |
| | | |||||
| * | Fix MemoryRecord bugs re error handling and add test coverage (#1448) | Taras | 2018-04-18 | 4 | -8/+75 |
| | | |||||
| * | Always acquire client lock before coordinator lock to avoid deadlocks (#1464) | Dana Powers | 2018-04-18 | 1 | -59/+64 |
| | | |||||
| * | Improve BrokerConnection initialization (#1475) | Rômulo Rosa Furtado | 2018-04-15 | 1 | -1/+1 |
| | | |||||
| * | Fix CreatePartitionsRequest_v0 (#1469) | Stephen SORRIAUX | 2018-04-05 | 1 | -1/+1 |
| | | |||||
| * | Adds add_callback/add_errback example to docs (#1441) | Berkodev | 2018-03-29 | 1 | -0/+12 |
| | | |||||
| * | Heartbeat thread start / close | Dana Powers | 2018-03-23 | 1 | -2/+4 |
| | | |||||
| * | Change levels for some heartbeat thread logging | Dana Powers | 2018-03-23 | 1 | -3/+3 |
| | | |||||
| * | Fix KafkaConsumer docstring for request_timeout_ms default (#1459) | Dana Powers | 2018-03-23 | 3 | -5/+5 |
| | | |||||
| * | Change SimpleProducer to use async_send (async is reserved in py37) (#1454) | Dana Powers | 2018-03-23 | 7 | -34/+42 |
| | | |||||
| * | Check for immediate failure when looking up coordinator in heartbeat thread ↵ | Dana Powers | 2018-03-23 | 1 | -1/+5 |
| | | | | | (#1457) | ||||
| * | Fix skipped integration tests if KAFKA_VERSION unset (#1453) | Dana Powers | 2018-03-22 | 2 | -0/+9 |
| | | |||||
| * | Bump version for development | Dana Powers | 2018-03-10 | 1 | -1/+1 |
| | | |||||
| * | 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 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |