| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Fix producerconfigs documentation link (#2226) | MandarJKulkarni | 2021-08-03 | 1 | -1/+1 |
| | | |||||
| * | Fix typo: veriication -> verification (#2207) | Dongwook Chan | 2021-02-21 | 1 | -1/+1 |
| | | | | Co-authored-by: will.k <will.k@kakaocorp.com> | ||||
| * | Support configuration of custom kafka client for Admin/Consumer/Producer (#2144) | Tincu Gabriel | 2020-12-02 | 1 | -4/+7 |
| | | |||||
| * | producer/kafka: Disable logging during object destruction (#2043) | Gioele | 2020-09-07 | 1 | -0/+8 |
| | | |||||
| * | Add support for `zstd` compression (#2021) | Tincu Gabriel | 2020-09-07 | 1 | -2/+6 |
| | | |||||
| * | Add `log_start_offset` to message protocol parsing (#2020) | Tincu Gabriel | 2020-03-25 | 3 | -13/+30 |
| | | | | This is in preparation for adding `zstd` support. | ||||
| * | Remove some dead code | Jeff Widman | 2020-02-05 | 1 | -179/+0 |
| | | |||||
| * | Do not block on sender thread join after timeout in producer.close() (#1974) | Dana Powers | 2019-12-29 | 1 | -5/+1 |
| | | |||||
| * | Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918) | Swen Wenzel | 2019-12-29 | 1 | -5/+5 |
| | | |||||
| * | Improve docs for reconnect_backoff_max_ms (#1976) | Dana Powers | 2019-12-28 | 1 | -5/+6 |
| | | |||||
| * | Fix typos | Carson Ip | 2019-11-08 | 1 | -1/+1 |
| | | |||||
| * | Remove SimpleClient, Producer, Consumer, Unittest (#1196) | Jeff Widman | 2019-10-11 | 4 | -589/+1 |
| | | | | | | | | | | | | | | | | | | | In the 2.0 release, we're removing: * `SimpleClient` * `SimpleConsumer` * `SimpleProducer` * Old partitioners used by `SimpleProducer`; these are superceded by the `DefaultPartitioner` These have been deprecated for several years in favor of `KafkaClient` / `KafkaConsumer` / `KafkaProducer`. Since 2.0 allows breaking changes, we are removing the deprecated classes. Additionally, since the only usage of `unittest` was in tests for these old Simple* clients, this also drops `unittest` from the library. All tests now run under `pytest`. | ||||
| * | Improve/refactor bootstrap_connected | Dana Powers | 2019-09-30 | 2 | -11/+11 |
| | | |||||
| * | Added a function to determine if bootstrap is successfully connected (#1876) | PandllCom | 2019-09-30 | 1 | -7/+14 |
| | | |||||
| * | Rely on socket selector to detect completed connection attempts (#1909) | Dana Powers | 2019-09-28 | 1 | -1/+1 |
| | | |||||
| * | Remove unused/weird comment line (#1813) | Jeff Widman | 2019-05-28 | 1 | -1/+0 |
| | | |||||
| * | Update docs for api_version_auto_timeout_ms (#1812) | Jeff Widman | 2019-05-24 | 1 | -1/+1 |
| | | | | | | | | | | The docs for `api_version_auto_timeout_ms` mention setting `api_version='auto'` but that value has been deprecated for years in favor of `api_version=None`. Updating the docs for now, and will remove support for `'auto'` in next major version bump. | ||||
| * | Dont do client wakeup when sending from sender thread (#1761) | Dana Powers | 2019-03-24 | 1 | -2/+3 |
| | | |||||
| * | Update sasl configuration docstrings | Dana Powers | 2019-03-23 | 1 | -5/+5 |
| | | |||||
| * | Support SASL OAuthBearer Authentication (#1750) | Phong Pham | 2019-03-22 | 1 | -1/+4 |
| | | |||||
| * | Allow configuration of SSL Ciphers (#1755) | Dana Powers | 2019-03-21 | 1 | -0/+6 |
| | | |||||
| * | Remove unused import | Jeff Widman | 2019-01-28 | 1 | -1/+0 |
| | | |||||
| * | #1681 add copy() in metrics() to avoid thread safety issues (#1682) | Tosi Émeric | 2018-12-27 | 1 | -2/+2 |
| | | |||||
| * | Be explicit with tuples for %s formatting | Jeff Widman | 2018-11-18 | 6 | -13/+13 |
| | | | | | Fix #1633 | ||||
| * | 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 | 1 | -0/+1 |
| | | |||||
| * | Stop using deprecated log.warn() | Jeff Widman | 2018-10-26 | 1 | -3/+3 |
| | | | | | I missed this in my previous cleanup back in 9221fcf83528b5c3657e43636cb84c1d18025acd. | ||||
| * | Vendor `six` consistently | Jeff Widman | 2018-10-22 | 1 | -2/+2 |
| | | | | | Use vendored `six`, and also `six.moves.range` rather than `xrange` | ||||
| * | Update remote urls: snappy, https, etc | Jeff Widman | 2018-10-22 | 1 | -2/+2 |
| | | | | | | Snappy URL was outdated. Similarly, many of these sites now support https. | ||||
| * | Support produce with Kafka record headers | Heikki Nousiainen | 2018-09-27 | 3 | -17/+27 |
| | | |||||
| * | add kerberos domain name config for gssapi sasl mechanism handshake (#1542) | the-sea | 2018-08-31 | 1 | -1/+4 |
| | | |||||
| * | add support for smaller topic metadata fetch during bootstrap (#1541) | Ning Xie | 2018-08-31 | 1 | -0/+1 |
| | | |||||
| * | Document connections_max_idle_ms | Jeff Widman | 2018-06-26 | 1 | -0/+5 |
| | | | | | | This was added in #1068 but never documented. Fix #1497 | ||||
| * | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 3 | -8/+8 |
| | | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
| * | Stop shadowing `ConnectionError` | Jeff Widman | 2018-05-23 | 1 | -1/+0 |
| | | | | | | | | | | | 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. | ||||
| * | Change SimpleProducer to use async_send (async is reserved in py37) (#1454) | Dana Powers | 2018-03-23 | 3 | -17/+25 |
| | | |||||
| * | 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 | 1 | -2/+1 |
| | | |||||
| * | Fix byte size estimation with kafka producer (#1393) | Blake Embrey | 2018-02-24 | 1 | -1/+1 |
| | | |||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 8 | -33/+33 |
| | | |||||
| * | fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352) | C.YAO | 2018-01-23 | 1 | -1/+1 |
| | | |||||
| * | Read all available socket bytes (#1332) | Dana Powers | 2018-01-10 | 1 | -0/+2 |
| | | | | | * Recv all available network bytes before parsing * Add experimental support for configuring socket chunking parameters | ||||
| * | Raise non-API exceptions (#1316) | Jeff Widman | 2017-12-21 | 1 | -5/+1 |
| | | | | | | | | | | | | | | The original intent was to catch API exceptions (errors returned by the broker when trying to produce a message) and delegate them to the messages' futures. This is copied from the Java producer. However, we were accidentally catching all exceptions, thereby hiding exceptions from users unless they explicitly check the result of the future. Much better to raise client-side errors directly in the foreground so the user is immediately aware of them and can decide how to handle. Fix #1274 | ||||
| * | use python standard max value (#1303) | lukeWx | 2017-12-07 | 2 | -2/+2 |
| | | |||||
| * | Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵ | Taras Voinarovskyi | 2017-10-25 | 2 | -6/+18 |
| | | | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls. | ||||
| * | Fix timestamp not passed to RecordMetadata (#1273) | Taras Voinarovskyi | 2017-10-22 | 2 | -7/+8 |
| | | | | | | | | | * Fix timestamp not being passed to RecordMetadata properly * Add more tests for LegacyBatch * Fix producer test for recordmetadata | ||||
| * | Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer ↵ | Nathanael Smith | 2017-10-17 | 1 | -0/+3 |
| | | | | | (#1264) | ||||
| * | Added minor fixes for PR review | Taras | 2017-10-12 | 2 | -16/+4 |
| | | |||||
| * | Remove the check for timestamp None in producer, as it's done in RecordBatch ↵ | Taras | 2017-10-12 | 1 | -2/+0 |
| | | | | | | | anyway. Minor abc doc fixes. | ||||
| * | Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵ | Taras | 2017-10-11 | 4 | -180/+90 |
| | | | | | message format | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |