| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Fix more gssapi errorsmore_sasl_fixes | Dana Powers | 2017-10-24 | 1 | -1/+4 |
| | | |||||
| * | Add fixture support for upcoming 1.0.0 broker release (#1275) | Dana Powers | 2017-10-23 | 4 | -2/+194 |
| | | |||||
| * | Fix timestamp not passed to RecordMetadata (#1273) | Taras Voinarovskyi | 2017-10-22 | 6 | -24/+195 |
| | | | | | | | | | * Fix timestamp not being passed to RecordMetadata properly * Add more tests for LegacyBatch * Fix producer test for recordmetadata | ||||
| * | Fixup for PR 1264 -- required to propagate configuration to BrokerConnection | Dana Powers | 2017-10-21 | 1 | -0/+3 |
| | | |||||
| * | Fixup for PR 1258 / _try_authenticate | Dana Powers | 2017-10-21 | 1 | -1/+4 |
| | | |||||
| * | Added controlled thread shutdown to example.py (#1268) | Benn Roth | 2017-10-21 | 1 | -8/+32 |
| | | |||||
| * | Merge pull request #1258 from dpkp/pending_completions | Taras Voinarovskyi | 2017-10-21 | 4 | -31/+65 |
| |\ | | | | | Move callback processing from BrokerConnection to KafkaClient | ||||
| | * | Move callback processing from BrokerConnection to KafkaClientpending_completions | Dana Powers | 2017-10-15 | 4 | -31/+65 |
| | | | |||||
| * | | 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 | 26 | -461/+1317 |
| |\ | | | | | 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 | 6 | -27/+20 |
| | | | |||||
| | * | Fix tests and rebase problems | Taras | 2017-10-12 | 2 | -97/+28 |
| | | | |||||
| | * | Added specific to record/ folder micro benchmarks to get exact speed change ↵ | Taras | 2017-10-12 | 3 | -0/+155 |
| | | | | | | | | | after updating to V2 message format | ||||
| | * | 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 | 21 | -355/+1142 |
| | | | | | | | | | message format | ||||
| * | | Merge pull request #1247 from dpkp/add_makefile | Taras Voinarovskyi | 2017-10-14 | 2 | -0/+72 |
| |\ \ | | | | | | | Add a Makefile | ||||
| | * | | Add build_intergation job for makefileadd_makefile | Taras Voinarovskiy | 2017-10-14 | 1 | -6/+11 |
| | | | | |||||
| | * | | Forgot the requirement-dev.txt file | Taras | 2017-10-14 | 1 | -0/+15 |
| | | | | |||||
| | * | | Add a Makefile, so users with less knowladge can easily build the project, ↵ | Taras | 2017-10-14 | 1 | -0/+52 |
| | |/ | | | | | | | generate docs and run tests. | ||||
| * | | KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254) | Dana Powers | 2017-10-11 | 5 | -26/+78 |
| |/ | |||||
| * | Merge pull request #1245 from dpkp/KAFKA_3977_defer_fetch_parsing | Taras Voinarovskyi | 2017-10-11 | 2 | -277/+537 |
| |\ | | | | | KAFKA-3977: defer fetch response parsing and raise exceptions to user | ||||
| | * | More testsKAFKA_3977_defer_fetch_parsing | Dana Powers | 2017-10-08 | 2 | -15/+200 |
| | | | |||||
| | * | Avoid sys.maxint; not supported on py3 | Dana Powers | 2017-10-08 | 1 | -2/+4 |
| | | | |||||
| | * | Add tests for Fetcher.fetched_records and _handle_fetch_response | Dana Powers | 2017-10-07 | 1 | -14/+118 |
| | | | |||||
| | * | 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 |
| | | | |||||
| * | | Update to 0.11.0.1 for travis test fixture; use as default if unspecified ↵ | Dana Powers | 2017-10-08 | 6 | -3/+191 |
| | | | | | | | | | (#1244) | ||||
| * | | Expand metrics docs (#1243) | Jeff Widman | 2017-10-08 | 3 | -13/+33 |
| |/ | | | | | | * 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 | 3 | -1/+50 |
| | | |||||
| * | Add method to ensure a valid topic name (#1238) | Niklas Mollenhauer | 2017-10-07 | 2 | -3/+53 |
| | | |||||
| * | 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 | 2 | -3/+31 |
| | | | | | 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 | 5 | -13/+13 |
| |\ | | | | | | | | | 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 | 5 | -13/+13 |
| | | | | | | | | | | | | | | | | | 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 |
| |/ | |||||
| * | Merge pull request #1200 from buptljy/offset | Taras Voinarovskyi | 2017-09-10 | 2 | -14/+0 |
| |\ | | | | | remove beginning/end offsets request version limit | ||||
| | * | remove beginning/end offsets request version limit | Liao Jiayi | 2017-09-04 | 2 | -14/+0 |
| |/ | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |