| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Minor Exception cleanupminor-exception-cleanup | Jeff Widman | 2017-12-07 | 7 | -10/+10 |
| | | |||||
| * | 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 |