| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | 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 | ||||
| * | Expand metrics docs (#1243) | Jeff Widman | 2017-10-08 | 1 | -6/+15 |
| | | | | | | | * Expand metrics docstrings * Document metrics interface in readme * Use six.iteritems(d) rather than d.items() * Use Sphinx warning syntax | ||||
| * | Remove a few unused imports (#1188) | James Lamb | 2017-08-29 | 1 | -1/+1 |
| | | | | | | * Removed a few unused imports * Added note on socketpair monkey-path | ||||
| * | Drop unused sleep kwarg to poll (#1177) | Dana Powers | 2017-08-15 | 1 | -1/+1 |
| | | |||||
| * | Fix batch expiry messages to state seconds | Dominic Evans | 2017-07-26 | 1 | -3/+3 |
| | | | | | | time.time() is seconds since epoch, and the deltas are also calculated in seconds | ||||
| * | Add note, that `max_in_flight_requests_per_connection>1` may change order or ↵ | Taras Voinarovskyi | 2017-07-17 | 1 | -1/+4 |
| | | | | | messages (#1149) | ||||
| * | producer: fix produce timeout message (#1151) | Mika Eloranta | 2017-07-17 | 1 | -1/+1 |
| | | |||||
| * | Use logging's built-in string interpolation | Jeff Widman | 2017-07-07 | 1 | -2/+1 |
| | | |||||
| * | producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126) | Hannu Valtonen | 2017-06-19 | 1 | -1/+1 |
| | | | | | | | | | Hit a problem with pytest hitting the atexit handler and waiting for close() timeout forever at teardown. This commit makes atexit close() equivalent to __del__ behavior, namely using timeout of 0 for close() completion. If you need a longer timeout you should be setting it explicitly. | ||||
| * | KIP-144: Exponential backoff for broker reconnections (#1124) | Dana Powers | 2017-06-19 | 1 | -0/+9 |
| | | |||||
| * | Update exception docstring | Andrew Kowalik | 2017-06-16 | 1 | -1/+1 |
| | | |||||
| * | raise KafkaTimeoutException when flush times out | Andrew Kowalik | 2017-06-16 | 2 | -2/+9 |
| | | |||||
| * | Improve error message when expiring batches in KafkaProducer (#1077) | Dana Powers | 2017-05-03 | 1 | -7/+11 |
| | | |||||
| * | Follow-up to #1068: remove not-implemented comments | Dana Powers | 2017-04-10 | 1 | -1/+1 |
| | | |||||
| * | Timeout idle connections via connections_max_idle_ms (#1068) | Dana Powers | 2017-04-10 | 1 | -1/+1 |
| | | |||||
| * | Fixup :meth: sphinx documentation for use in KafkaConsumer.rst etc | Dana Powers | 2017-03-07 | 1 | -12/+14 |
| | | |||||
| * | change default timeout of KafkaProducer.close() to threading.TIMEOUT_MAX | gaosheng | 2017-03-06 | 1 | -2/+6 |
| | | |||||
| * | Add sphinx formatting to hyperlink methods (#898) | Jeff Widman | 2017-03-03 | 2 | -11/+13 |
| | | |||||
| * | Replace %s with %r in producer debug log message (#973) | Alex | 2017-03-03 | 1 | -1/+1 |
| | | |||||
| * | Issue 985: Clear memory wait condition before raising Exception (#999) | Dana Powers | 2017-03-02 | 1 | -0/+1 |
| | | |||||
| * | Fix BrokerConnection api_version docs default (#909) | Jeff Widman | 2017-02-28 | 1 | -4/+4 |
| | | |||||
| * | PEP-8: Spacing & removed unused imports (#899) | Jeff Widman | 2017-02-09 | 2 | -6/+6 |
| | | |||||
| * | Add kafka.serializer interfaces (#912) | Dana Powers | 2016-12-19 | 1 | -12/+13 |
| | | |||||
| * | Sort partitions before calling partitioner (#905) | ms7s | 2016-12-19 | 1 | -1/+1 |
| | | |||||
| * | Fixup doc references to max_in_flight_requests_per_connection | Dana Powers | 2016-12-17 | 2 | -2/+2 |
| | | |||||
| * | DOC: Fix typo 'Defualt' -> 'Default'. (#895) | Rolando (Max) Espinoza | 2016-11-30 | 1 | -1/+1 |
| | | |||||
| * | :wPass timestamp into Message, not just mimic it (#875) | Taras Voinarovskyi | 2016-11-18 | 1 | -2/+6 |
| | | |||||
| * | Fix typos | Jeff Widman | 2016-11-14 | 1 | -1/+1 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |