diff options
Diffstat (limited to 'kafka/consumer')
| -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 5330e9f..38d4571 100644 --- a/kafka/consumer/subscription_state.py +++ b/kafka/consumer/subscription_state.py @@ -172,6 +172,7 @@ class SubscriptionState(object): for tp in assignments: self._add_assigned_partition(tp) self.needs_partition_assignment = False + log.info("Updated partition assignment: %s", assignments) def unsubscribe(self): self.subscription = None |