openstack/deb-python-kafka
Code Issues Proposed changes

Fix raise exception from SubscriptionState.assign_from_subscribed (#960)

Browse Source
This commit is contained in:
Petr Šebek
2017-02-03 18:45:57 +01:00
committed by Dana Powers
parent 641b6399d8
commit ce1bdee2ec
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/consumer/subscription_state.py
View File

@@ -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)