| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | 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 | 1 | -1/+1 |
| | | |||||
| * | Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵ | Taras Voinarovskyi | 2017-10-25 | 1 | -4/+11 |
| | | | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls. | ||||
| * | 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 | 1 | -1/+1 |
| | | |||||
| * | 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 | 1 | -9/+34 |
| | | | | | 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 | ||||
| * | 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 |
| | | |||||
| * | 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 | 1 | -0/+4 |
| | | |||||
| * | 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 | 1 | -8/+8 |
| | | |||||
| * | Replace %s with %r in producer debug log message (#973) | Alex | 2017-03-03 | 1 | -1/+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 | 1 | -4/+4 |
| | | |||||
| * | 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 | 1 | -1/+1 |
| | | |||||
| * | DOC: Fix typo 'Defualt' -> 'Default'. (#895) | Rolando (Max) Espinoza | 2016-11-30 | 1 | -1/+1 |
| | | |||||
| * | Added ssl_password config option to KafkaProducer class, identical to… (#830) | kierkegaard13 | 2016-09-15 | 1 | -0/+3 |
| | | | | | | | | | * Added ssl_password config option to KafkaProducer class, identical to option in KafkaConsumer class * removed non-ascii characters * changed - to : in comments | ||||
| * | Improve KafkaProducer docstring re retries config | Dana Powers | 2016-08-20 | 1 | -3/+5 |
| | | |||||
| * | Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metrics | Dana Powers | 2016-08-04 | 1 | -1/+1 |
| | | |||||
| * | Fix misspelling of "password" (#793) | Samuel Taylor | 2016-08-04 | 1 | -1/+1 |
| | | |||||
| * | implement sasl PLAIN mechanism | Lars Jørgen Solberg | 2016-08-03 | 1 | -1/+12 |
| | | |||||
| * | Clarify api_version=str deprecation warning | Dana Powers | 2016-08-02 | 1 | -1/+1 |
| | | |||||
| * | Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788) | Dana Powers | 2016-08-01 | 1 | -2/+2 |
| | | | | - also update internal classes RecordAccumulator and Sender | ||||
| * | Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783) | Dana Powers | 2016-08-01 | 1 | -0/+5 |
| | | |||||
| * | Add KafkaClient metricsmore_metrics | Dana Powers | 2016-07-17 | 1 | -1/+2 |
| | | |||||
| * | KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord ↵ | Dana Powers | 2016-07-17 | 1 | -4/+6 |
| | | | | | (#770 / #594) | ||||
| * | Expose selector type as config option (#764) | Dana Powers | 2016-07-16 | 1 | -1/+5 |
| | | |||||
| * | Update kafka configuration links -> 0.10.0.0 docs | Dana Powers | 2016-07-16 | 1 | -1/+1 |
| | | |||||
| * | First stab at public metrics() interface for KafkaConsumer / KafkaProducer | Dana Powers | 2016-07-16 | 1 | -0/+15 |
| | | |||||
| * | Add initial producer-sender metrics | Dana Powers | 2016-07-16 | 1 | -2/+23 |
| | | |||||
| * | Add api_version config to KafkaClient, deprecate str in favor of tuples (#761) | Dana Powers | 2016-07-16 | 1 | -12/+18 |
| | | |||||
| * | Avoid AttributeErrors in _unregister_cleanup (#747) | Dana Powers | 2016-07-05 | 1 | -1/+1 |
| | | |||||
| * | allow client.check_version timeout to be set in Producer and Consumer ↵ | eastlondoner | 2016-06-29 | 1 | -1/+5 |
| | | | | | | constructors (#647) * allow client.check_version timeout to be set in Producer and Consumer constructors | ||||
| * | Clarify timeout unit (#734) | ms7s | 2016-06-21 | 1 | -1/+8 |
| | | |||||
| * | Use weakref when registering a producer.close atexit to fix normal gc (#728) | Dana Powers | 2016-06-18 | 1 | -3/+37 |
| | | | | | * Use weakref when registering a producer.close atexit to fix normal gc * Test that del(producer) terminates async thread | ||||
| * | KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to ↵ | Dana Powers | 2016-05-22 | 1 | -0/+2 |
| | | | | | guarantee ordering (#698) | ||||
| * | Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694) | Dana Powers | 2016-05-22 | 1 | -1/+2 |
| | | |||||
| * | KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ↵ | Dana Powers | 2016-05-22 | 1 | -4/+11 |
| | | | | | messagesets | ||||
| * | Add CRL support to SSL support (#683) | Vincent Bernat | 2016-05-19 | 1 | -0/+6 |
| | | | | | A user can provide a CRL whose peer certificate will be checked against. This only works with Python 3.4+ and Python 2.7.9+. | ||||
| * | Add protocol support for ApiVersionRequest; identify 0.10 brokers in ↵check_version_0_10 | Dana Powers | 2016-05-02 | 1 | -1/+1 |
| | | | | | check_version | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |