gistfile1.txt

2015-10-14 06:45:44,520 (MainThread) Data inserted 384
Traceback (most recent call last):
  File "/usr/local/bin/eventlogging-consumer", line 5, in <module>
    pkg_resources.run_script('eventlogging==0.9-20150929', 'eventlogging-consumer')
  File "/usr/lib/python2.7/dist-packages/pkg_resources.py", line 528, in run_script
    self.require(requires)[0].run_script(script_name, ns)
  File "/usr/lib/python2.7/dist-packages/pkg_resources.py", line 1394, in run_script
    execfile(script_filename, namespace, namespace)
  File "/usr/local/lib/python2.7/dist-packages/eventlogging-0.9_20150929-py2.7.egg/EGG-INFO/scripts/eventlogging-consumer", line 50, in <module>
    eventlogging.drive(args.input, args.output)
  File "/usr/local/lib/python2.7/dist-packages/eventlogging-0.9_20150929-py2.7.egg/eventlogging/factory.py", line 124, in drive
    writer.send(event)
StopIteration

gistfile2.txt

2015-10-14 06:47:04,339 (Thread-15 ) Autocommitting consumer offset for consumer group mysql-m4-master and topic eventlogging-valid-mixed
Exception in thread Thread-14:
Traceback (most recent call last):
  File "/usr/lib/python2.7/threading.py", line 810, in __bootstrap_inner
    self.run()
  File "/usr/lib/python2.7/threading.py", line 763, in run
    self.__target(*self.__args, **self.__kwargs)
  File "/usr/lib/python2.7/dist-packages/pykafka/simpleconsumer.py", line 269, in fetcher
    self.fetch()
  File "/usr/lib/python2.7/dist-packages/pykafka/simpleconsumer.py", line 500, in fetch
    min_bytes=self._fetch_min_bytes
  File "/usr/lib/python2.7/dist-packages/pykafka/broker.py", line 222, in fetch_messages
    return future.get(FetchResponse)
  File "/usr/lib/python2.7/dist-packages/pykafka/handlers.py", line 55, in get
    raise self.error
timeout: timed out