diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-29 17:04:24 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-29 17:16:04 -0800 |
| commit | ab1578444c79703610228531beef259478614338 (patch) | |
| tree | ee290cc4af0b8ac11de95a3c29edacf1685cf80a /kafka/consumer | |
| parent | 2a2733d4fc725f04461a6c4d0ca0fc253f99caeb (diff) | |
| download | kafka-python-ab1578444c79703610228531beef259478614338.tar.gz | |
Log as INFO: group join, leader election, partition assignments
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 |