openstack/deb-python-kafka
Code Issues Proposed changes

Remove extra raise and old TODO comment in coordinators

Browse Source
This commit is contained in:
Dana Powers
2015-12-29 16:59:59 -08:00
parent aa35c4e424
commit b7d1ed3fb4
2 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
kafka/coordinator/abstract.py
View File

@@ -329,7 +329,6 @@ class AbstractCoordinator(object):
response.group_protocol,
response.members)
except Exception as e:
raise
return Future().failure(e)
request = SyncGroupRequest(

2
kafka/coordinator/consumer.py
View File

@@ -69,7 +69,7 @@ class ConsumerCoordinator(AbstractCoordinator):
raise Errors.IllegalStateError('Coordinator requires assignors')
self._cluster.request_update()
self._cluster.add_listener(self._handle_metadata_update) #TODO
self._cluster.add_listener(self._handle_metadata_update)
if self._enable_auto_commit:
interval = self._auto_commit_interval_ms / 1000.0