Traceback (most recent call last):


 "/usr/lib/python2.7/threading.py", line 801, in __bootstrap_inner

self.run()


 "/usr/lib/python2.7/threading.py", line 754, in run

self.__target(*self.__args, **self.__kwargs)


 "/usr/lib/python2.7/site-packages/kafka/util.py", line 135, in _timer

self.fn(*self.args, **self.kwargs)


 "/usr/lib/python2.7/site-packages/kafka/consumer/base.py", line 164, in commit

self.client.send_offset_commit_request(self.group, reqs)


 "/usr/lib/python2.7/site-packages/kafka/client.py", line 685, in send_offset_commit_request

resps = self._send_broker_aware_request(payloads, encoder, decoder)


 "/usr/lib/python2.7/site-packages/kafka/client.py", line 286, in _send_broker_aware_request

conn.recv()


 "/usr/lib/python2.7/site-packages/kafka/conn.py", line 586, in recv

return self._recv()


 "/usr/lib/python2.7/site-packages/kafka/conn.py", line 593, in _recv

data = self._sock.recv(bytes_to_read)
ValueError: negative buffersize in recv

>>> Traceback (most recent call last):

 "/home/malfatti/NotSynced/SoftwareTest/spyder/spyderlib/widgets/variableexplorer/namespacebrowser.py", line 282, in toggle_auto_refresh
"set_monitor_auto_refresh(%r)" % state)

 "/home/malfatti/NotSynced/SoftwareTest/spyder/spyderlib/utils/bsdsocket.py", line 104, in communicate
write_packet(sock, command)

 "/home/malfatti/NotSynced/SoftwareTest/spyder/spyderlib/utils/bsdsocket.py", line 51, in write_packet
nsend -= temp_fail_retry(socket.error, sock.send, sent_data)

 "/home/malfatti/NotSynced/SoftwareTest/spyder/spyderlib/utils/bsdsocket.py", line 31, in temp_fail_retry
return fun(*args)BrokenPipeError: [Errno 32] Broken pipe