Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Cover sticky assignor's metadata method with tests (#2161) | Valeria Chernenko | 2020-11-05 | 1 | -3/+7 |
| | |||||
* | Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154) | Valeria Chernenko | 2020-10-30 | 1 | -1/+1 |
| | |||||
* | KIP-54: Implement sticky partition assignment strategy (#2057) | Valeria Chernenko | 2020-09-29 | 4 | -0/+893 |
| | |||||
* | A little python cleanup (#1805) | Jeff Widman | 2019-05-17 | 1 | -4/+2 |
| | | | | | | 1. Remove unused variable: `partitions_for_topic` 2. No need to cast to list as `sorted()` already returns a list 3. Using `enumerate()` is cleaner than `range(len())` and handles assigning `member` | ||||
* | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 1 | -1/+1 |
| | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
* | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 2 | -5/+5 |
| | |||||
* | Add comment for round robin partitioner with different subscriptions | Dana Powers | 2016-08-20 | 1 | -0/+15 |
| | |||||
* | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 3 | -0/+6 |
| | |||||
* | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 2 | -2/+2 |
| | |||||
* | Add RangePartitionAssignor (and use as default); add assignor testsrange_assignor | Dana Powers | 2016-02-16 | 2 | -1/+94 |
| | |||||
* | Move ConsumerProtocol definition to kafka.coordinator.protocol | Dana Powers | 2016-01-10 | 1 | -1/+1 |
| | |||||
* | Use python3 compatible next() in roundrobin assignor | Dana Powers | 2016-01-01 | 1 | -2/+2 |
| | |||||
* | More Docstring Improvements | Dana Powers | 2015-12-30 | 1 | -4/+23 |
| | |||||
* | ConsumerCoordinator (based on upstream Java client) | Dana Powers | 2015-12-28 | 3 | -0/+98 |
- Use RoundRobinPartitionAssignor by default - Define AbstractPartitionAssignor for custom assignors - metrics still TODO |