| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Give better struct errorsbetter-struct-errors | Jeff Widman | 2017-12-07 | 1 | -4/+8 |
| | | | | | | | | | | | Stop shadowing the word `error` because we want to know what the specific exception message was. Also give more details on exactly which value failed. We don't know who submitted the value, but perhaps it's unique enough that we can debug it better. Fix #1318 | ||||
| * | use python standard max value (#1303) | lukeWx | 2017-12-07 | 4 | -4/+4 |
| | | |||||
| * | changed for to use enumerate() (#1301) | Benn Roth | 2017-12-06 | 1 | -2/+1 |
| | | |||||
| * | Change fixture default host to localhost (#1305) | Andre Araujo | 2017-12-05 | 1 | -15/+1 |
| | | |||||
| * | Fix two bugs in printing bytes instance | Andre Araujo | 2017-11-27 | 1 | -1/+1 |
| | | | | | | | | | | Bug 1: When `value` is None, trying to call `len(None)` throws an exception. Bug 2: When len(`value`) <= 100, the code currently prints b'' rather than `value`. | ||||
| * | Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239 | Dana Powers | 2017-11-16 | 2 | -30/+2 |
| | | | | | The change caused a regression documented in issue #1290 | ||||
| * | Use correct casing for MB | Jeff Widman | 2017-11-15 | 2 | -2/+2 |
| | | | | | | | These values refer to Megabytes, not Megabits. Fix #1295 | ||||
| * | Replace periods (java) with underscores (python) | Jeff Widman | 2017-11-07 | 1 | -2/+2 |
| | | |||||
| * | Add license to wheel | Jeff Widman | 2017-11-03 | 1 | -0/+3 |
| | | | | https://wheel.readthedocs.io/en/stable/index.html#including-the-license-in-the-generated-wheel-file | ||||
| * | Use socket timeout of request_timeout_ms to prevent blocking forever on send ↵ | Dana Powers | 2017-10-25 | 1 | -6/+7 |
| | | | | | (#1281) | ||||
| * | Handle lookup_coordinator send failures (#1279) | Dana Powers | 2017-10-24 | 2 | -5/+19 |
| | | |||||
| * | Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵ | Taras Voinarovskyi | 2017-10-25 | 18 | -31/+1696 |
| | | | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls. | ||||
| * | Fix more gssapi errors (#1280) | 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 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |