| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | Move callback processing from BrokerConnection to KafkaClientpending_completions | Dana Powers | 2017-10-15 | 3 | -30/+63 | |
| | | | ||||||
| * | | Explicitly check for None rather than falsey | Jeff Widman | 2017-10-19 | 1 | -3/+3 | |
| | | | | | | | | | Be pedantic about checking for identity rather than equality to avoid issues like #1237 / 411bc08f214b7afc36f11bde2047096c06467088 | |||||
| * | | Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer ↵ | Nathanael Smith | 2017-10-17 | 2 | -0/+6 | |
| | | | | | | | | | (#1264) | |||||
| * | | Cleanup gssapi code; fix bug report re AttributeError. (#1262) | Dana Powers | 2017-10-16 | 1 | -10/+9 | |
| | | | ||||||
| * | | Fix docstring | Jeff Widman | 2017-10-16 | 1 | -3/+4 | |
| |/ | ||||||
| * | Fix SASL authentication bugs (#1257) | Dana Powers | 2017-10-15 | 1 | -23/+34 | |
| | | | | | | | * Use _send_bytes_blocking in BrokerConnection * _try_authenticate should call recv() so that futures are resolved * _sasl_auth_future can be reset if recv() causes disconnect * validate sasl_mechanism against SaslHandShakeResponse enabled_mechanisms | |||||
| * | Merge pull request #1252 from dpkp/legacy_records_refactor | Taras Voinarovskyi | 2017-10-14 | 16 | -281/+922 | |
| |\ | | | | | Refactor MessageSet and Message into LegacyRecordBatch | |||||
| | * | Added limit of 100 bytes for Bytes debug printslegacy_records_refactor | Taras Voinarovskiy | 2017-10-14 | 1 | -0/+4 | |
| | | | ||||||
| | * | Added minor fixes for PR review | Taras | 2017-10-12 | 4 | -18/+7 | |
| | | | ||||||
| | * | Fix tests and rebase problems | Taras | 2017-10-12 | 1 | -2/+1 | |
| | | | ||||||
| | * | Remove the check for timestamp None in producer, as it's done in RecordBatch ↵ | Taras | 2017-10-12 | 3 | -22/+7 | |
| | | | | | | | | | | | | | anyway. Minor abc doc fixes. | |||||
| | * | Fix snappy compression on PyPy | Taras | 2017-10-12 | 1 | -4/+5 | |
| | | | ||||||
| | * | Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵ | Taras | 2017-10-11 | 15 | -270/+933 | |
| | | | | | | | | | message format | |||||
| * | | KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254) | Dana Powers | 2017-10-11 | 4 | -21/+74 | |
| |/ | ||||||
| * | Merge pull request #1245 from dpkp/KAFKA_3977_defer_fetch_parsing | Taras Voinarovskyi | 2017-10-11 | 1 | -261/+237 | |
| |\ | | | | | KAFKA-3977: defer fetch response parsing and raise exceptions to user | |||||
| | * | More testsKAFKA_3977_defer_fetch_parsing | Dana Powers | 2017-10-08 | 1 | -0/+5 | |
| | | | ||||||
| | * | Avoid sys.maxint; not supported on py3 | Dana Powers | 2017-10-08 | 1 | -2/+4 | |
| | | | ||||||
| | * | KAFKA-3977: Defer fetch parsing for space efficiency, and to raise ↵ | Dana Powers | 2017-10-07 | 1 | -261/+230 | |
| | | | | | | | | | exceptions to user | |||||
| * | | Check for disconnects during ssl handshake and sasl authentication (#1249) | Dana Powers | 2017-10-10 | 1 | -31/+42 | |
| | | | ||||||
| * | | Always wait for completion during SASL/GSSAPI authentication (#1248) | Dana Powers | 2017-10-10 | 1 | -26/+15 | |
| | | | ||||||
| * | | Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230) | Dana Powers | 2017-10-10 | 3 | -146/+226 | |
| | | | ||||||
| * | | Expand metrics docs (#1243) | Jeff Widman | 2017-10-08 | 2 | -10/+26 | |
| |/ | | | | | | * Expand metrics docstrings * Document metrics interface in readme * Use six.iteritems(d) rather than d.items() * Use Sphinx warning syntax | |||||
| * | Bump version for development | Dana Powers | 2017-10-07 | 1 | -1/+1 | |
| | | ||||||
| * | Release 1.3.51.3.5 | Dana Powers | 2017-10-07 | 1 | -1/+1 | |
| | | ||||||
| * | Add method to ensure a valid topic name (#1238) | Niklas Mollenhauer | 2017-10-07 | 1 | -3/+28 | |
| | | ||||||
| * | Fix typo | Jeff Widman | 2017-10-06 | 1 | -1/+1 | |
| | | ||||||
| * | Explicitly check for `None` rather than False | Jeff Widman | 2017-10-06 | 1 | -1/+1 | |
| | | | | | | If the group leader somehow gets in a state that it has an empty partition assignment, then `self._assignment_snapshot` will be `{}` which evaluates to `False`. So `self._subscription.mark_for_reassignment()` will never be triggered, even if `self._assignment_snapshot != self._metadata_snapshot`. Fixes the symptoms of https://github.com/dpkp/kafka-python/issues/1237 although I suspect there's an additional bug in that case that triggers the condition of the the group leader getting an empty partition assignment. | |||||
| * | Fix Fetcher.PartitionRecords to handle fetch_offset in the middle of ↵ | Dana Powers | 2017-10-05 | 1 | -2/+7 | |
| | | | | | compressed messageset (#1239) | |||||
| * | Fix grammar | Jeff Widman | 2017-10-04 | 1 | -1/+1 | |
| | | ||||||
| * | Small fixes to SASL documentation and logging; validate security_protocol ↵ | Dana Powers | 2017-10-03 | 1 | -21/+26 | |
| | | | | | (#1231) | |||||
| * | Remove raw traceback (#1221) | dbgasaway | 2017-10-01 | 1 | -3/+5 | |
| | | ||||||
| * | Merge pull request #1213 from ↵ | Taras Voinarovskyi | 2017-09-13 | 1 | -9/+9 | |
| |\ | | | | | | | | | dpkp/1212-stop-using-mutable-types-for-default-arg-values Stop using mutable types for default arg values | |||||
| | * | Stop using mutable types for default arg values1212-stop-using-mutable-types-for-default-arg-values | Jeff Widman | 2017-09-12 | 1 | -9/+9 | |
| | | | | | | | | | | | | | | | | | Using mutable types for default args is typically a no-no unless their surprising behavior is being explicitly abused, for an explanation see: http://effbot.org/zone/default-values.htm Fix #1212 | |||||
| * | | Fix typo | Jeff Widman | 2017-09-12 | 1 | -1/+1 | |
| |/ | ||||||
| * | remove beginning/end offsets request version limit | Liao Jiayi | 2017-09-04 | 1 | -8/+0 | |
| | | ||||||
| * | Remove a few unused imports (#1188) | James Lamb | 2017-08-29 | 4 | -4/+3 | |
| | | | | | | * Removed a few unused imports * Added note on socketpair monkey-path | |||||
| * | BrokerConnection receive bytes pipe (#1032) | Dana Powers | 2017-08-15 | 4 | -93/+121 | |
| | | ||||||
| * | Drop unused sleep kwarg to poll (#1177) | Dana Powers | 2017-08-15 | 4 | -14/+9 | |
| | | ||||||
| * | bump version for development | Dana Powers | 2017-08-13 | 1 | -1/+1 | |
| | | ||||||
| * | Release 1.3.41.3.4 | Dana Powers | 2017-08-13 | 1 | -1/+1 | |
| | | ||||||
| * | Initialize metadata_snapshot in group coordinator (#1174) | Dana Powers | 2017-08-13 | 1 | -6/+9 | |
| | | ||||||
| * | Select on sockets to avoid busy polling during bootstrap (#1175) | Dana Powers | 2017-08-13 | 1 | -0/+2 | |
| | | ||||||
| * | Added unit tests for fetcher's `_reset_offset` and related functions. | Taras Voinarovskiy | 2017-08-07 | 1 | -5/+16 | |
| | | ||||||
| * | Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵ | Taras Voinarovskiy | 2017-08-07 | 3 | -16/+96 | |
| | | | | | review issues | |||||
| * | Fix test for older brokers | Taras Voinarovskiy | 2017-08-07 | 1 | -1/+1 | |
| | | ||||||
| * | Changed retrieve_offsets to allow fetching multiple offsets at once | Taras Voinarovskiy | 2017-08-07 | 2 | -96/+133 | |
| | | ||||||
| * | Added basic support for offsets_for_times API. Still needs to group by nodes ↵ | Taras Voinarovskiy | 2017-08-07 | 5 | -20/+124 | |
| | | | | | and send in parallel. | |||||
| * | Add private map of api key -> min/max versions to BrokerConnection (#1169) | Dana Powers | 2017-08-06 | 2 | -11/+58 | |
| | | ||||||
| * | Fixed Issue 1033.Raise AssertionError when decompression unsupported. (#1159) | webber | 2017-08-05 | 1 | -0/+7 | |
| | | ||||||
| * | conn: Catch ssl.EOFErrors on Python3.3 so we close the failing conn (#1162) | Hannu Valtonen | 2017-08-01 | 1 | -1/+3 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |