| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Dont refresh metadata on failed group coordinator request unless needed (#1006) | Dana Powers | 2017-03-03 | 1 | -6/+4 | |
| | | ||||||
| * | Add sphinx formatting to hyperlink methods (#898) | Jeff Widman | 2017-03-03 | 1 | -5/+5 | |
| | | ||||||
| * | PEP-8: Spacing & removed unused imports (#899) | Jeff Widman | 2017-02-09 | 1 | -6/+6 | |
| | | ||||||
| * | Fix possible request draining in ensure_active_group (#896) | Dana Powers | 2016-12-02 | 1 | -3/+6 | |
| | | ||||||
| * | Always include an error for logging when the coordinator is marked dead (#890) | Dana Powers | 2016-11-18 | 2 | -9/+9 | |
| | | ||||||
| * | Add comment for round robin partitioner with different subscriptions | Dana Powers | 2016-08-20 | 1 | -0/+15 | |
| | | ||||||
| * | Drain pending requests to the coordinator before initiating group rejoin (#798) | Dana Powers | 2016-08-04 | 1 | -0/+8 | |
| | | ||||||
| * | Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ↵ | Dana Powers | 2016-08-04 | 1 | -4/+4 | |
| | | | | | group test (#795) | |||||
| * | Treat metric_group_prefix as config in KafkaConsumer | Dana Powers | 2016-08-04 | 2 | -8/+7 | |
| | | ||||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 4 | -0/+8 | |
| | | ||||||
| * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 4 | -4/+4 | |
| | | ||||||
| * | Add base coordinator metrics | Dana Powers | 2016-07-17 | 3 | -76/+80 | |
| | | ||||||
| * | KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626) | Dana Powers | 2016-07-17 | 1 | -44/+8 | |
| | | ||||||
| * | KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701) | Dana Powers | 2016-07-17 | 1 | -10/+24 | |
| | | ||||||
| * | KAFKA-2832: Add a consumer config option to exclude internal topics (#765) | Dana Powers | 2016-07-17 | 1 | -4/+8 | |
| | | | | | Use exclude_internal_topics config in KafkaConsumer to avoid subscribe patterns matching internal topics Raise error during rebalance if subscribed topics are not authorized | |||||
| * | Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706) | Dana Powers | 2016-07-16 | 2 | -20/+25 | |
| | | | | | * Dont wait for group join to enable AutoCommitTask if broker version < 0.9 * For zookeeper offset storage, set a "coordinator" with least_loaded_node | |||||
| * | Avoid some exceptions in Coordinator.__del__ (#668) | Dana Powers | 2016-04-25 | 2 | -2/+4 | |
| | | ||||||
| * | Changing some commented out metrics to avoid future gotchas. | Zack Dever | 2016-04-13 | 1 | -3/+3 | |
| | | ||||||
| * | Beginnings of metrics instrumentation in kafka consumer. | Zack Dever | 2016-04-13 | 1 | -41/+30 | |
| | | | | | | | This adds the parent metrics instance to kafka consumer, which will eventually be used to instrument everything under consumer. To start I ported the java consumer coordinator metrics. | |||||
| * | Default sleep=True in client.poll | Dana Powers | 2016-04-08 | 1 | -1/+1 | |
| | | ||||||
| * | Can no longer have coordinator_id if coordinator_unknown() | Dana Powers | 2016-04-08 | 1 | -6/+0 | |
| | | ||||||
| * | Use version-indexed lists for request/response protocol structsprotocol_versions | Dana Powers | 2016-04-05 | 2 | -24/+21 | |
| | | ||||||
| * | Remove unused importskafka-3318 | Dana Powers | 2016-04-05 | 1 | -2/+0 | |
| | | ||||||
| * | KAFKA-3318: clean up consumer logging and error messages | Dana Powers | 2016-04-05 | 2 | -78/+103 | |
| | | ||||||
| * | Update imports from kafka.common -> kafka.errors / kafka.structs | Dana Powers | 2016-04-05 | 4 | -5/+5 | |
| | | ||||||
| * | Merge pull request #589 from dpkp/node_not_ready | Dana Powers | 2016-04-04 | 1 | -8/+14 | |
| |\ | | | | | Refactor NodeNotReadyError handling | |||||
| | * | Improve Coordinator Error handling | Dana Powers | 2016-04-04 | 1 | -8/+14 | |
| | | | | | | | | | | | | | | | - coordinator_unknown() should not check ready(node_id) - dont mark coordinator dead on not-ready or inflight-requests errors - improve coordinator and heartbeat logging - dont gate group metadata requests on ready() check [conn handles now] | |||||
| * | | Improve auto-commit task handling when group_id is Noneissue_619 | Dana Powers | 2016-04-03 | 1 | -20/+22 | |
| |/ | ||||||
| * | Check for None returned from least_loaded_node when no brokers are availablenone_least_loaded_node | Dana Powers | 2016-03-13 | 1 | -0/+4 | |
| | | ||||||
| * | Log successful heartbeat as INFO; improve heartbeat response logging | Dana Powers | 2016-03-12 | 1 | -11/+12 | |
| | | ||||||
| * | HeartbeatTask should reschedule heartbeat on coordinator_unknown() | Dana Powers | 2016-03-12 | 1 | -2/+6 | |
| | | ||||||
| * | Mock client.ready() call to test coordinator offset fetch request | Dana Powers | 2016-02-19 | 1 | -1/+2 | |
| | | ||||||
| * | Some attributes may not exist in __del__ if we failed assertions | Dana Powers | 2016-02-18 | 1 | -1/+1 | |
| | | ||||||
| * | More friendly warning when offset fetch request returns unknown topic / ↵ | Dana Powers | 2016-02-18 | 1 | -1/+2 | |
| | | | | | partition | |||||
| * | Verify node ready before sending offset fetch request from coordinator | Dana Powers | 2016-02-18 | 1 | -0/+5 | |
| | | ||||||
| * | break up some circular references and close client wake pipe on __del__ | aisch | 2016-02-16 | 2 | -6/+21 | |
| | | ||||||
| * | 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 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |