| Commit message (Expand) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Add KafkaConsumer.highwater(partition) to get highwater offsets from FetchRes... | Dana Powers | 2016-01-31 | 1 | -0/+1 |
| * | KAFKA-2978: consumer stops fetching when consumed and fetch positions get out... | Dana Powers | 2016-01-10 | 1 | -23/+11 |
| * | Add error checking to mark_for_reassignment | Dana Powers | 2016-01-10 | 1 | -0/+3 |
| * | Prefer assert or more-specific error to IllegalState / IllegalArgument | Dana Powers | 2015-12-30 | 1 | -6/+3 |
| * | More Docstring Improvements | Dana Powers | 2015-12-30 | 1 | -22/+91 |
| * | Log as INFO: group join, leader election, partition assignments | Dana Powers | 2015-12-29 | 1 | -0/+1 |
| * | Improve various docstrings | Dana Powers | 2015-12-29 | 1 | -3/+10 |
| * | Make add_assigned_partition private(ish) in SubscriptionState | Dana Powers | 2015-12-29 | 1 | -3/+3 |
| * | Define ConsumerRebalanceListener abstract class | Dana Powers | 2015-12-28 | 1 | -0/+84 |
| * | New class SubscriptionState, based on upstream Java client | Dana Powers | 2015-12-28 | 1 | -0/+304 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |