| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Fix typo in file namefix-typod-test-file-name | Jeff Widman | 2018-10-22 | 1 | -0/+0 |
| | | |||||
| * | Support produce with Kafka record headers | Heikki Nousiainen | 2018-09-27 | 5 | -18/+40 |
| | | |||||
| * | Expose record headers in ConsumerRecords | Heikki Nousiainen | 2018-09-27 | 3 | -6/+13 |
| | | |||||
| * | Add positive tests for headers in record encode/decode | Heikki Nousiainen | 2018-09-27 | 2 | -3/+18 |
| | | |||||
| * | Expose ConsumerRebalanceListener in all | Ben Harack | 2018-09-27 | 1 | -1/+1 |
| | | | | | | | This solves a warning in linters like PyCharm, which warns that a line like: from kafka import ConsumerRebalanceListener is actually accessing a protected member of a class or module. Adding it to __all__ should solve this. | ||||
| * | Remove ConsumerTimeout | Jonathan Emord | 2018-09-27 | 1 | -4/+0 |
| | | |||||
| * | Clear the metrics dictionary on close. (#1569) | Kishore Nallan | 2018-08-31 | 1 | -0/+2 |
| | | |||||
| * | Return future from commit_offsets_async (#1560) | Mike Lang | 2018-08-31 | 1 | -1/+6 |
| | | |||||
| * | add kerberos domain name config for gssapi sasl mechanism handshake (#1542) | the-sea | 2018-08-31 | 4 | -4/+17 |
| | | |||||
| * | add support for smaller topic metadata fetch during bootstrap (#1541) | Ning Xie | 2018-08-31 | 3 | -6/+14 |
| | | |||||
| * | Document connections_max_idle_ms | Jeff Widman | 2018-06-26 | 3 | -0/+15 |
| | | | | | | This was added in #1068 but never documented. Fix #1497 | ||||
| * | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 16 | -36/+32 |
| | | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
| * | Bump version for development | Dana Powers | 2018-05-26 | 1 | -1/+1 |
| | | |||||
| * | Release 1.4.31.4.3 | Dana Powers | 2018-05-26 | 3 | -1/+85 |
| | | |||||
| * | Retain but deprecate kafka.errors.ConnectionError for compatibility | Dana Powers | 2018-05-26 | 1 | -0/+4 |
| | | |||||
| * | Improve connection handling when bootstrap list is invalid (#1507) | Dana Powers | 2018-05-26 | 1 | -6/+3 |
| | | | | | * only perform single dns lookup for connect_blocking() * fix blocking timeout in check_version() | ||||
| * | Ignore MetadataResponses with empty broker list (#1506) | Dana Powers | 2018-05-26 | 3 | -1/+28 |
| | | |||||
| * | Document methods that return None | Jeff Widman | 2018-05-23 | 1 | -0/+3 |
| | | | | | | If a valid broker in the cluster has no partitions, it will return None rather than an empty set. Similarly updated a few other methods. | ||||
| * | Stop shadowing `ConnectionError` | Jeff Widman | 2018-05-23 | 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. | ||||
| * | Stop using deprecated log.warn() | Jeff Widman | 2018-05-10 | 1 | -3/+3 |
| | | |||||
| * | 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 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |