Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
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
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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.