| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | 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 |
| | | |||||
| * | 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 | 3 | -8/+17 |
| | | |||||
| * | Instrument metrics in BrokerConnection | Dana Powers | 2016-08-04 | 1 | -17/+0 |
| | | |||||
| * | 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 |
| | | |||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 1 | -0/+2 |
| | | |||||
| * | Clarify api_version=str deprecation warning | Dana Powers | 2016-08-02 | 1 | -1/+1 |
| | | |||||
| * | Merge pull request #785 from dpkp/six | Dana Powers | 2016-08-01 | 3 | -3/+3 |
| |\ | | | | | Vendor python module six; move selectors34 and socketpair under kafka.vendor | ||||
| | * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 3 | -3/+3 |
| | | | |||||
| * | | Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788) | Dana Powers | 2016-08-01 | 3 | -6/+6 |
| |/ | | | - 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 |
| | | |||||
| * | Record produce latency and throttling metrics | Dana Powers | 2016-07-17 | 1 | -4/+9 |
| | | |||||
| * | Avoid buffer overread when compressing messageset in KafkaProducer | Dana Powers | 2016-07-17 | 1 | -1/+2 |
| | | |||||
| * | KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord ↵ | Dana Powers | 2016-07-17 | 4 | -16/+30 |
| | | | | | (#770 / #594) | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |