From ce1bdee2ecda6279f062e1bdafa07fbbf747845e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Petr=20=C5=A0ebek?= Date: Fri, 3 Feb 2017 18:45:57 +0100 Subject: Fix raise exception from SubscriptionState.assign_from_subscribed (#960) --- kafka/consumer/subscription_state.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/consumer/subscription_state.py b/kafka/consumer/subscription_state.py index 9e7f080..19046ae 100644 --- a/kafka/consumer/subscription_state.py +++ b/kafka/consumer/subscription_state.py @@ -225,7 +225,7 @@ class SubscriptionState(object): for tp in assignments: if tp.topic not in self.subscription: - raise ValueError("Assigned partition %s for non-subscribed topic." % tp) + raise ValueError("Assigned partition %s for non-subscribed topic." % str(tp)) self.assignment.clear() for tp in assignments: self._add_assigned_partition(tp) -- cgit v1.2.1