summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Collapse)AuthorAgeFilesLines
* Give better struct errorsbetter-struct-errorsJeff Widman2017-12-071-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)lukeWx2017-12-074-4/+4
|
* changed for to use enumerate() (#1301)Benn Roth2017-12-061-2/+1
|
* Fix two bugs in printing bytes instanceAndre Araujo2017-11-271-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 #1239Dana Powers2017-11-161-7/+2
| | | | The change caused a regression documented in issue #1290
* Use correct casing for MBJeff Widman2017-11-152-2/+2
| | | | | | These values refer to Megabytes, not Megabits. Fix #1295
* Replace periods (java) with underscores (python)Jeff Widman2017-11-071-2/+2
|
* Use socket timeout of request_timeout_ms to prevent blocking forever on send ↵Dana Powers2017-10-251-6/+7
| | | | (#1281)
* Handle lookup_coordinator send failures (#1279)Dana Powers2017-10-241-5/+11
|
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵Taras Voinarovskyi2017-10-2510-23/+932
| | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.
* Fix more gssapi errors (#1280)Dana Powers2017-10-241-1/+4
|
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-224-16/+56
| | | | | | | | * 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 BrokerConnectionDana Powers2017-10-211-0/+3
|
* Fixup for PR 1258 / _try_authenticateDana Powers2017-10-211-1/+4
|
* Merge pull request #1258 from dpkp/pending_completionsTaras Voinarovskyi2017-10-213-30/+63
|\ | | | | Move callback processing from BrokerConnection to KafkaClient
| * Move callback processing from BrokerConnection to KafkaClientpending_completionsDana Powers2017-10-153-30/+63
| |
* | Explicitly check for None rather than falseyJeff Widman2017-10-191-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 Smith2017-10-172-0/+6
| | | | | | | | (#1264)
* | Cleanup gssapi code; fix bug report re AttributeError. (#1262)Dana Powers2017-10-161-10/+9
| |
* | Fix docstringJeff Widman2017-10-161-3/+4
|/
* Fix SASL authentication bugs (#1257)Dana Powers2017-10-151-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_refactorTaras Voinarovskyi2017-10-1416-281/+922
|\ | | | | Refactor MessageSet and Message into LegacyRecordBatch
| * Added limit of 100 bytes for Bytes debug printslegacy_records_refactorTaras Voinarovskiy2017-10-141-0/+4
| |
| * Added minor fixes for PR reviewTaras2017-10-124-18/+7
| |
| * Fix tests and rebase problemsTaras2017-10-121-2/+1
| |
| * Remove the check for timestamp None in producer, as it's done in RecordBatch ↵Taras2017-10-123-22/+7
| | | | | | | | | | | | anyway. Minor abc doc fixes.
| * Fix snappy compression on PyPyTaras2017-10-121-4/+5
| |
| * Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-1115-270/+933
| | | | | | | | message format
* | KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)Dana Powers2017-10-114-21/+74
|/
* Merge pull request #1245 from dpkp/KAFKA_3977_defer_fetch_parsingTaras Voinarovskyi2017-10-111-261/+237
|\ | | | | KAFKA-3977: defer fetch response parsing and raise exceptions to user
| * More testsKAFKA_3977_defer_fetch_parsingDana Powers2017-10-081-0/+5
| |
| * Avoid sys.maxint; not supported on py3Dana Powers2017-10-081-2/+4
| |
| * KAFKA-3977: Defer fetch parsing for space efficiency, and to raise ↵Dana Powers2017-10-071-261/+230
| | | | | | | | exceptions to user
* | Check for disconnects during ssl handshake and sasl authentication (#1249)Dana Powers2017-10-101-31/+42
| |
* | Always wait for completion during SASL/GSSAPI authentication (#1248)Dana Powers2017-10-101-26/+15
| |
* | Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230)Dana Powers2017-10-103-146/+226
| |
* | Expand metrics docs (#1243)Jeff Widman2017-10-082-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 developmentDana Powers2017-10-071-1/+1
|
* Release 1.3.51.3.5Dana Powers2017-10-071-1/+1
|
* Add method to ensure a valid topic name (#1238)Niklas Mollenhauer2017-10-071-3/+28
|
* Fix typoJeff Widman2017-10-061-1/+1
|
* Explicitly check for `None` rather than FalseJeff Widman2017-10-061-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 Powers2017-10-051-2/+7
| | | | compressed messageset (#1239)
* Fix grammarJeff Widman2017-10-041-1/+1
|
* Small fixes to SASL documentation and logging; validate security_protocol ↵Dana Powers2017-10-031-21/+26
| | | | (#1231)
* Remove raw traceback (#1221)dbgasaway2017-10-011-3/+5
|
* Merge pull request #1213 from ↵Taras Voinarovskyi2017-09-131-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-valuesJeff Widman2017-09-121-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 typoJeff Widman2017-09-121-1/+1
|/
* remove beginning/end offsets request version limitLiao Jiayi2017-09-041-8/+0
|
View Lorry Controller Status