pykafka error

2015-11-11 15:26:25,927 (Thread-9  ) Received EVENT: Watch(type=4, state=3, path=u'/kafka/eqiad/brokers/ids')
2015-11-11 15:26:25,928 (Thread-9  ) Sending request(xid=93): GetChildren(path='/kafka/eqiad/brokers/ids', watcher=<bound method ChildrenWatch._watcher of <kazoo.recipe.watchers.ChildrenWatch object at 0x7f055a0bde50>>)
2015-11-11 15:26:25,929 (Thread-9  ) Received response(xid=93): [u'22', u'18', u'13', u'14', u'12']
2015-11-11 15:26:25,931 (Thread-8  ) Attempting to discover offset manager for consumer group 'mysql-m4-master'
2015-11-11 15:26:25,932 (Thread-8  )
Traceback (most recent call last):
  File "/usr/lib/python2.7/dist-packages/kazoo/recipe/watchers.py", line 297, in _get_children
    result = self._func(children)
  File "/usr/lib/python2.7/dist-packages/pykafka/balancedconsumer.py", line 486, in _brokers_changed
    self._rebalance()
  File "/usr/lib/python2.7/dist-packages/pykafka/balancedconsumer.py", line 386, in _rebalance
    self.commit_offsets()
  File "/usr/lib/python2.7/dist-packages/pykafka/balancedconsumer.py", line 521, in commit_offsets
    return self._consumer.commit_offsets()
  File "/usr/lib/python2.7/dist-packages/pykafka/simpleconsumer.py", line 344, in commit_offsets
    partitions_by_id=self._partitions_by_id)
  File "/usr/lib/python2.7/dist-packages/pykafka/utils/error_handlers.py", line 55, in handle_partition_responses
    error_handlers[errcode](parts)
  File "/usr/lib/python2.7/dist-packages/pykafka/simpleconsumer.py", line 215, in _handle_NotCoordinatorForConsumer
    self._discover_offset_manager()
  File "/usr/lib/python2.7/dist-packages/pykafka/simpleconsumer.py", line 230, in _discover_offset_manager
    self._offset_manager = self._cluster.get_offset_manager(self._consumer_group)
  File "/usr/lib/python2.7/dist-packages/pykafka/cluster.py", line 252, in get_offset_manager
    res = future.get(ConsumerMetadataResponse)
  File "/usr/lib/python2.7/dist-packages/pykafka/handlers.py", line 55, in get
    raise self.error
SocketDisconnectedError
2015-11-11 15:26:25,933 (Thread-8  ) Exception in worker queue thread
Traceback (most recent call last):
  File "/usr/lib/python2.7/dist-packages/kazoo/handlers/threading.py", line 194, in thread_worker
    func()
  File "/usr/lib/python2.7/dist-packages/kazoo/handlers/threading.py", line 279, in <lambda>
    self.callback_queue.put(lambda: callback.func(*callback.args))
  File "/usr/lib/python2.7/dist-packages/kazoo/recipe/watchers.py", line 305, in _watcher
    self._get_children(event)
  File "/usr/lib/python2.7/dist-packages/kazoo/recipe/watchers.py", line 22, in wrapper
    return func(*args, **kwargs)
  File "/usr/lib/python2.7/dist-packages/kazoo/recipe/watchers.py", line 297, in _get_children
    result = self._func(children)
  File "/usr/lib/python2.7/dist-packages/pykafka/balancedconsumer.py", line 486, in _brokers_changed
    self._rebalance()
  File "/usr/lib/python2.7/dist-packages/pykafka/balancedconsumer.py", line 386, in _rebalance
    self.commit_offsets()
  File "/usr/lib/python2.7/dist-packages/pykafka/balancedconsumer.py", line 521, in commit_offsets
    return self._consumer.commit_offsets()
  File "/usr/lib/python2.7/dist-packages/pykafka/simpleconsumer.py", line 344, in commit_offsets
    partitions_by_id=self._partitions_by_id)
  File "/usr/lib/python2.7/dist-packages/pykafka/utils/error_handlers.py", line 55, in handle_partition_responses
    error_handlers[errcode](parts)
  File "/usr/lib/python2.7/dist-packages/pykafka/simpleconsumer.py", line 215, in _handle_NotCoordinatorForConsumer
    self._discover_offset_manager()
  File "/usr/lib/python2.7/dist-packages/pykafka/simpleconsumer.py", line 230, in _discover_offset_manager
    self._offset_manager = self._cluster.get_offset_manager(self._consumer_group)
  File "/usr/lib/python2.7/dist-packages/pykafka/cluster.py", line 252, in get_offset_manager
    res = future.get(ConsumerMetadataResponse)
  File "/usr/lib/python2.7/dist-packages/pykafka/handlers.py", line 55, in get
    raise self.error
SocketDisconnectedError