summaryrefslogtreecommitdiff
path: root/kafka/consumer/subscription_state.py
Commit message (Expand)AuthorAgeFilesLines
* Use explicit subscription state flag to handle seek() during message iterationcompacted_offsetsDana Powers2016-07-081-0/+2
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-1/+2
* KAFKA-2698: add paused APIZack Dever2016-03-161-0/+5
* Attempt to clarify error message on consumer subscribe/assign assert failureDana Powers2016-03-141-2/+5
* Add KafkaConsumer.highwater(partition) to get highwater offsets from FetchRes...Dana Powers2016-01-311-0/+1
* KAFKA-2978: consumer stops fetching when consumed and fetch positions get out...Dana Powers2016-01-101-23/+11
* Add error checking to mark_for_reassignmentDana Powers2016-01-101-0/+3
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-301-6/+3
* More Docstring ImprovementsDana Powers2015-12-301-22/+91
* Log as INFO: group join, leader election, partition assignmentsDana Powers2015-12-291-0/+1
* Improve various docstringsDana Powers2015-12-291-3/+10
* Make add_assigned_partition private(ish) in SubscriptionStateDana Powers2015-12-291-3/+3
* Define ConsumerRebalanceListener abstract classDana Powers2015-12-281-0/+84
* New class SubscriptionState, based on upstream Java clientDana Powers2015-12-281-0/+304