summaryrefslogtreecommitdiff
path: root/kafka/consumer/subscription_state.py
Commit message (Expand)AuthorAgeFilesLines
* 1701 use last offset from fetch v4 if available (#1724)Keith So2019-03-131-0/+5
* Be explicit with tuples for %s formattingJeff Widman2018-11-181-1/+1
* KAFKA-3949: Avoid race condition when subscription changes during rebalance (...Dana Powers2018-02-021-16/+14
* Add method to ensure a valid topic name (#1238)Niklas Mollenhauer2017-10-071-3/+28
* Fix raise exception from SubscriptionState.assign_from_subscribed (#960)Petr Ĺ ebek2017-02-031-1/+1
* Use six.string_types for topic type check in #824Dana Powers2016-11-201-2/+2
* Raise exception if given a bad topic name (#824)Samuel Taylor2016-11-201-0/+7
* Merge pull request #785 from dpkp/sixDana Powers2016-08-011-1/+1
|\
| * Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
* | Fix offset fetch when partitions are manually assigned (#786)Dana Powers2016-08-011-0/+1
|/
* 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