2015-04-01 03:02:36,056 - kafka - ERROR - Unable to receive data from Kafka
Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/conn.py", line 102, in _read_bytes
    raise socket.error("Not enough data to read message -- did server kill socket?")
error: Not enough data to read message -- did server kill socket?
2015-04-01 03:02:36,056 - kafka - DEBUG - Closing socket connection for 172.31.13.68:9092
2015-04-01 03:02:36,057 - kafka - WARNING - Could not receive response to request [-------my data-------here] from server <KafkaConnection host=172.31.13.68 port=9092>: Kafka @ 172.31.13.68:9092 went away
2015-04-01 03:02:36,057 - kafka - ERROR - Unable to send messages
Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/producer/base.py", line 199, in _send_messages
    timeout=self.ack_timeout)
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/client.py", line 417, in send_produce_request
    resps = self._send_broker_aware_request(payloads, encoder, decoder)
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/client.py", line 208, in _send_broker_aware_request
    raise FailedPayloadsError(failed_payloads)
FailedPayloadsError
2015-04-01 03:02:36,058 - api.apis.public.app - ERROR - Traceback (most recent call last):
  File "./api/apis/public/app.py", line 103, in on_post
    self.producer.send_messages('eyespage.applogs_json', *applogs_json)
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/producer/simple.py", line 77, in send_messages
    topic, partition, *msg
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/producer/base.py", line 173, in send_messages
    return self._send_messages(topic, partition, *msg)
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/producer/base.py", line 199, in _send_messages
    timeout=self.ack_timeout)
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/client.py", line 417, in send_produce_request
    resps = self._send_broker_aware_request(payloads, encoder, decoder)
  File "/usr/local/lib/python2.7/dist-packages/kafka_python-0.9.4_dev-py2.7.egg/kafka/client.py", line 208, in _send_broker_aware_request
    raise FailedPayloadsError(failed_payloads)
FailedPayloadsError