| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Add RangePartitionAssignor (and use as default); add assignor testsrange_assignor | Dana Powers | 2016-02-16 | 4 | -4/+98 |
| | | |||||
| * | Fixup: _send_offset_commit_request future should succeed w/ True, not None | Dana Powers | 2016-02-02 | 1 | -1/+2 |
| | | |||||
| * | Ok to sleep in blocking poll for metadata update | Dana Powers | 2016-01-25 | 1 | -1/+1 |
| | | |||||
| * | Disable offset commits and auto-partition-assignment when group_id is None | Dana Powers | 2016-01-24 | 1 | -8/+17 |
| | | |||||
| * | Dont need to refresh metadata on GroupCoordinatorNotAvailableErrors | Dana Powers | 2016-01-24 | 1 | -1/+4 |
| | | |||||
| * | KAFKA-2978: consumer stops fetching when consumed and fetch positions get ↵ | Dana Powers | 2016-01-10 | 1 | -1/+2 |
| | | | | | out of sync | ||||
| * | ConsumerCoordinator cleanups | Dana Powers | 2016-01-10 | 2 | -13/+36 |
| | | | | | | | | | | | | | | | - default assignors to RoundRobinPartitionAssignor - check offsets types in commit_offsets_* methods - succeed future in _send_offset_commit_request when no offsets - raise exception if no subscribed topics in group_protocols() - fix _subscription typo in metadata listener callbacks - short circuit if no partitions passed to fetch_committed_offsets - line-wrap comments - return future from commit_offsets_async - return future value from commit_offsets_sync - fix self._failed_request callback partial args - comment out metrics class for now | ||||
| * | Move ConsumerProtocol definition to kafka.coordinator.protocol | Dana Powers | 2016-01-10 | 3 | -35/+44 |
| | | |||||
| * | Fix future redefine bug in client.poll | Dana Powers | 2016-01-04 | 1 | -0/+1 |
| | | |||||
| * | Drop unused method from ConsumerCoordinator | Dana Powers | 2016-01-03 | 1 | -5/+0 |
| | | |||||
| * | Check api_version in ConsumerCoordinator | Dana Powers | 2016-01-03 | 1 | -32/+94 |
| | | | | | | | | - Full group support in 0.9 - Kafka-storage offsets w/ GroupCoordinator in 0.8.2 - Zookeeper-storage offsets in 0.8.1 - Assign all partitions locally if < 0.9 | ||||
| * | Use python3 compatible next() in roundrobin assignor | Dana Powers | 2016-01-01 | 1 | -2/+2 |
| | | |||||
| * | Fixup heartbeat config assertion | Dana Powers | 2015-12-31 | 1 | -1/+1 |
| | | |||||
| * | Rename AbstractCoordinator -> BaseCoordinator, log as kafka.coordinator | Dana Powers | 2015-12-30 | 2 | -5/+5 |
| | | |||||
| * | Prefer assert or more-specific error to IllegalState / IllegalArgument | Dana Powers | 2015-12-30 | 3 | -21/+8 |
| | | |||||
| * | Catch GroupCoordinatorNotAvailableError in GroupCoordinatorResponse handler | Dana Powers | 2015-12-30 | 1 | -0/+3 |
| | | |||||
| * | More Docstring Improvements | Dana Powers | 2015-12-30 | 3 | -30/+106 |
| | | |||||
| * | Rename KafkaClient.connection_failed -> is_disconnected | Dana Powers | 2015-12-30 | 1 | -1/+1 |
| | | |||||
| * | Make group_id a Coordinator kwarg (not arg) for consistency | Dana Powers | 2015-12-30 | 2 | -7/+5 |
| | | |||||
| * | Switch configs from attributes to dict to make passing / inspecting easier | Dana Powers | 2015-12-29 | 3 | -55/+63 |
| | | |||||
| * | Fix log statement bug (via pylint) | Dana Powers | 2015-12-29 | 1 | -1/+1 |
| | | |||||
| * | Clean more ConsumerCoordinator docstrings | Dana Powers | 2015-12-29 | 1 | -16/+19 |
| | | |||||
| * | Dont warn in AutoCommitTask.disable if not previously scheduled | Dana Powers | 2015-12-29 | 1 | -1/+1 |
| | | |||||
| * | Improve OffsetCommit error logging | Dana Powers | 2015-12-29 | 1 | -23/+33 |
| | | | | | | | Avoid printing full errors because they currently include long descriptions that are generally duplicative of our local error message. | ||||
| * | Log request failures in AbstractCoordinator._failed_request | Dana Powers | 2015-12-29 | 1 | -5/+10 |
| | | |||||
| * | _handle_group_coordinator_response should resolve future with the coordinator id | Dana Powers | 2015-12-29 | 1 | -1/+1 |
| | | |||||
| * | Improve heartbeat logging | Dana Powers | 2015-12-29 | 1 | -14/+13 |
| | | |||||
| * | Log as INFO: group join, leader election, partition assignments | Dana Powers | 2015-12-29 | 1 | -1/+4 |
| | | |||||
| * | Improve various docstrings | Dana Powers | 2015-12-29 | 2 | -19/+33 |
| | | |||||
| * | Remove extra raise and old TODO comment in coordinators | Dana Powers | 2015-12-29 | 2 | -2/+1 |
| | | |||||
| * | Make more methods private(ish) in AbstractCoordinator | Dana Powers | 2015-12-29 | 1 | -13/+13 |
| | | |||||
| * | Remove recursive client.poll call in ConsumerCoordinator | Dana Powers | 2015-12-29 | 1 | -2/+3 |
| | | |||||
| * | Pass auto commit parameters from KafkaConsumer to ConsumerCoordinator | Dana Powers | 2015-12-29 | 1 | -1/+1 |
| | | |||||
| * | Fix HeartbeatTask request_in_flight handling | Dana Powers | 2015-12-29 | 1 | -1/+1 |
| | | |||||
| * | ConsumerCoordinator (based on upstream Java client) | Dana Powers | 2015-12-28 | 4 | -0/+703 |
| | | | | | | | - Use RoundRobinPartitionAssignor by default - Define AbstractPartitionAssignor for custom assignors - metrics still TODO | ||||
| * | AbstractCoordinator (modelled after upstream Java class) | Dana Powers | 2015-12-28 | 3 | -0/+685 |
| - Heartbeat class manages HeartbeatRequest / Response state - metrics are still TODO | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |