| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Use TypeError for invalid type | Jeff Widman | 2018-11-17 | 1 | -1/+1 | |
| | | ||||||
| * | raising logging level on messages signalling data loss (#1553) | Alexander Sibiryakov | 2018-11-10 | 1 | -2/+3 | |
| | | ||||||
| * | set socket timeout for the wake_w (#1577) | flaneur | 2018-11-10 | 2 | -0/+6 | |
| | | ||||||
| * | (Attempt to) Fix deadlock between consumer and heartbeat (#1628) | Dana Powers | 2018-11-10 | 2 | -4/+2 | |
| | | ||||||
| * | Fix typo | Jeff Widman | 2018-11-07 | 1 | -1/+1 | |
| | | ||||||
| * | Pre-compile pack/unpack function calls | billyevans | 2018-10-29 | 1 | -13/+29 | |
| | | | | | | | | | | | | | | | | | I noticed that pack/unpack functions from https://github.com/dpkp/kafka-python/blob/master/kafka/protocol/types.py might be slightly improved. I made pre-compilation for them. It gives about 10% better performance compared to the current implementation. Consumption of 100msg: ``` 239884 0.187 0.000 0.287 0.000 types.py:18(_unpack) # new version 239884 0.192 0.000 0.323 0.000 types.py:17(_unpack) ``` I also made some profiling for producers/consumers. It gives about 1-1.5% time savings. | |||||
| * | Document KafkaAdmin class | Jeff Widman | 2018-10-29 | 1 | -0/+7 | |
| | | ||||||
| * | Stop using deprecated log.warn() | Jeff Widman | 2018-10-26 | 1 | -3/+3 | |
| | | | | | I missed this in my previous cleanup back in 9221fcf83528b5c3657e43636cb84c1d18025acd. | |||||
| * | Add temp workaround for upstream pylint bug | Jeff Widman | 2018-10-26 | 1 | -1/+3 | |
| | | | | | Temporarily workaround https://github.com/PyCQA/pylint/issues/2571 so that we can stop pinning `pylint`. | |||||
| * | Add KafkaAdmin class | Richard Lee | 2018-10-24 | 9 | -0/+637 | |
| | | | | | | | Requires cluster version > 0.10.0.0, and uses new wire protocol classes to do many things via broker connection that previously needed to be done directly in zookeeper. | |||||
| * | Vendor enum34 | Jeff Widman | 2018-10-22 | 1 | -0/+841 | |
| | | | | | | | | | | This is needed for https://github.com/dpkp/kafka-python/pull/1540 While the usage there is trivial and could probably be worked around, I'd rather vendor it so that future code can use enums... since `enum` is already available in the python 3 stdlib, this will be easy enough to eventually stop vendoring whenever we finally drop python 2 support. | |||||
| * | Vendor `six` consistently | Jeff Widman | 2018-10-22 | 2 | -4/+4 | |
| | | | | | Use vendored `six`, and also `six.moves.range` rather than `xrange` | |||||
| * | Update remote urls: snappy, https, etc | Jeff Widman | 2018-10-22 | 3 | -5/+5 | |
| | | | | | | Snappy URL was outdated. Similarly, many of these sites now support https. | |||||
| * | Bump vendored `six` to `1.11.0` | Jeff Widman | 2018-10-22 | 1 | -16/+42 | |
| | | | | | | | | | | Bump `six` to `1.11.0`. Most changes do not affect us, but it's good to stay up to date. Also, we will likely start vendoring `enum34` in which case https://github.com/benjaminp/six/pull/178 is needed. Note that this preserves the `kafka-python` customization from https://github.com/dpkp/kafka-python/pull/979 which has been submitted upstream as https://github.com/benjaminp/six/pull/176 but not yet merged. | |||||
| * | Support produce with Kafka record headers | Heikki Nousiainen | 2018-09-27 | 3 | -17/+27 | |
| | | ||||||
| * | Expose record headers in ConsumerRecords | Heikki Nousiainen | 2018-09-27 | 1 | -3/+5 | |
| | | ||||||
| * | 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 | 10 | -23/+18 | |
| | | | | | 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 | 1 | -1/+1 | |
| | | ||||||
| * | 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 | 2 | -1/+6 | |
| | | ||||||
| * | 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 | 5 | -25/+24 | |
| | | | | | | | | | | | 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 | |
| | | ||||||
| * | 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 | 2 | -6/+34 | |
| | | ||||||
| * | Fix MemoryRecord bugs re error handling and add test coverage (#1448) | Taras | 2018-04-18 | 3 | -7/+7 | |
| | | ||||||
| * | 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 | |
| | | ||||||
| * | 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 | 3 | -17/+25 | |
| | | ||||||
| * | Check for immediate failure when looking up coordinator in heartbeat thread ↵ | Dana Powers | 2018-03-23 | 1 | -1/+5 | |
| | | | | | (#1457) | |||||
| * | Bump version for development | Dana Powers | 2018-03-10 | 1 | -1/+1 | |
| | | ||||||
| * | Patch Release 1.4.21.4.2 | Dana Powers | 2018-03-10 | 1 | -1/+1 | |
| | | ||||||
| * | KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to ↵ | Dana Powers | 2018-03-10 | 1 | -0/+4 | |
| | | | | | 0 (#1439) | |||||
| * | Remove old CommitFailed error message from coordinator (#1436) | Dana Powers | 2018-03-10 | 1 | -11/+1 | |
| | | ||||||
| * | Validate that serializers generate bytes-like (or None) data (#1420) | Dana Powers | 2018-03-10 | 1 | -2/+3 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |