Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
| * | | 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 | |
|/ | ||||||
* | 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 | 5 | -31/+25 | |
| | ||||||
* | Update sphinx/RTD changelog for 1.3.4 | Dana Powers | 2017-08-13 | 2 | -1/+68 | |
| | ||||||
* | bump version for development | Dana Powers | 2017-08-13 | 1 | -1/+1 | |
| | ||||||
* | Update compatibility docs re: 0.11 brokers and python 3.6 | Dana Powers | 2017-08-13 | 3 | -13/+13 | |
| | ||||||
* | Release 1.3.41.3.4 | Dana Powers | 2017-08-13 | 2 | -1/+59 | |
| | ||||||
* | Add 0.11.0.0 to travis test matrix, remove 0.10.1.1; use scala 2.11 ↵ | Dana Powers | 2017-08-13 | 2 | -30/+18 | |
| | | | | artifacts (#1176) | |||||
* | 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 | |
| | ||||||
* | Merge pull request #1161 from dpkp/issue1036_offset_by_time | Taras Voinarovskyi | 2017-08-07 | 7 | -68/+609 | |
|\ | | | | | Added support for offsets_for_times, beginning_offsets and end_offsets APIs. | |||||
| * | Added unit tests for fetcher's `_reset_offset` and related functions. | Taras Voinarovskiy | 2017-08-07 | 3 | -7/+199 | |
| | | ||||||
| * | Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵ | Taras Voinarovskiy | 2017-08-07 | 4 | -17/+142 | |
| | | | | | | | | 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 | 3 | -100/+174 | |
| | | ||||||
| * | Fix test for older brokers | Taras Voinarovskiy | 2017-08-07 | 1 | -2/+4 | |
| | | ||||||
| * | Added basic support for offsets_for_times API. Still needs to group by nodes ↵ | Taras Voinarovskiy | 2017-08-07 | 6 | -21/+169 | |
|/ | | | | 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 | |
| | ||||||
* | Merge pull request #1160 from dpkp/issue1155 | Taras Voinarovskyi | 2017-07-31 | 1 | -0/+1 | |
|\ | | | | | Make UnknownTopicOrPartitionError retriable error | |||||
| * | Make UnknownTopicOrPartitionError retriable errorissue1155 | Taras Voinarovskiy | 2017-07-30 | 1 | -0/+1 | |
|/ |