diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-08-01 16:30:03 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-08-01 16:30:03 -0700 |
| commit | ec286c9fb6a49b20a3cdce473b03b55fe43d0e43 (patch) | |
| tree | 3a3631fd18e003b37421c7ad93d3fa95c4f4229d | |
| parent | 41bed56fb98f3ef297a9c19205b224dfd928dd46 (diff) | |
| download | kafka-python-ec286c9fb6a49b20a3cdce473b03b55fe43d0e43.tar.gz | |
Fix offset fetch when partitions are manually assigned (#786)
| -rw-r--r-- | kafka/consumer/subscription_state.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/consumer/subscription_state.py b/kafka/consumer/subscription_state.py index fa09a06..d054fc5 100644 --- a/kafka/consumer/subscription_state.py +++ b/kafka/consumer/subscription_state.py @@ -199,6 +199,7 @@ class SubscriptionState(object): del self.assignment[tp] self.needs_partition_assignment = False + self.needs_fetch_committed_offsets = True def assign_from_subscribed(self, assignments): """Update the assignment to the specified partitions |