Traceback (most recent call last):


 "mapper/pm_mapper.py", line 34, in <module>

kafka_consumers[topic] = kafka_client.topics[topic].get_simple_consumer(consumer_group='task-runner', auto_commit_enable=True)


 "/usr/lib/python2.7/site-packages/pykafka/topic.py", line 196, in get_simple_consumer

**kwargs)


 "/usr/lib/python2.7/site-packages/pykafka/simpleconsumer.py", line 190, in __init__

self._discover_group_coordinator()


 "/usr/lib/python2.7/site-packages/pykafka/simpleconsumer.py", line 321, in _discover_group_coordinator

self._group_coordinator = self._cluster.get_group_coordinator(self._consumer_group)


 "/usr/lib/python2.7/site-packages/pykafka/cluster.py", line 412, in get_group_coordinator

future = broker.handler.request(req)
AttributeError: 'NoneType' object has no attribute 'request'

Traceback (most recent call last):


 "/usr/local/bin/celery", line 11, in <module>

sys.exit(main())


 "/usr/local/lib/python3.4/dist-packages/celery/__main__.py", line 14, in main

_main()


 "/usr/local/lib/python3.4/dist-packages/celery/bin/celery.py", line 326, in main

cmd.execute_from_commandline(argv)


 "/usr/local/lib/python3.4/dist-packages/celery/bin/celery.py", line 488, in execute_from_commandline

super(CeleryCommand, self).execute_from_commandline(argv)))


 "/usr/local/lib/python3.4/dist-packages/celery/bin/base.py", line 278, in execute_from_commandline

return self.handle_argv(self.prog_name, argv[1:])


 "/usr/local/lib/python3.4/dist-packages/celery/bin/celery.py", line 480, in handle_argv

return self.execute(command, argv)


 "/usr/local/lib/python3.4/dist-packages/celery/bin/celery.py", line 412, in execute

).run_from_argv(self.prog_name, argv[1:], command=argv[0])


 "/usr/local/lib/python3.4/dist-packages/celery/bin/worker.py", line 221, in run_from_argv

return self(*args, **options)


 "/usr/local/lib/python3.4/dist-packages/celery/bin/base.py", line 241, in __call__

ret = self.run(*args, **kwargs)


 "/usr/local/lib/python3.4/dist-packages/celery/bin/worker.py", line 255, in run

**kwargs)


 "/usr/local/lib/python3.4/dist-packages/celery/worker/worker.py", line 99, in __init__

self.setup_instance(**self.prepare_args(**kwargs))


 "/usr/local/lib/python3.4/dist-packages/celery/worker/worker.py", line 139, in setup_instance

self.blueprint.apply(self, **kwargs)


 "/usr/local/lib/python3.4/dist-packages/celery/bootsteps.py", line 214, in apply

step.include(parent)


 "/usr/local/lib/python3.4/dist-packages/celery/bootsteps.py", line 343, in include

return self._should_include(parent)[0]


 "/usr/local/lib/python3.4/dist-packages/celery/bootsteps.py", line 339, in _should_include

return True, self.create(parent)


 "/usr/local/lib/python3.4/dist-packages/celery/worker/components.py", line 214, in create

w._persistence = w.state.Persistent(w.state, w.statedb, w.app.clock)


 "/usr/local/lib/python3.4/dist-packages/celery/worker/state.py", line 189, in __init__

self.merge()


 "/usr/local/lib/python3.4/dist-packages/celery/worker/state.py", line 197, in merge

self._merge_with(self.db)


 "/usr/local/lib/python3.4/dist-packages/celery/worker/state.py", line 213, in _merge_with

self._merge_revoked(d)


 "/usr/local/lib/python3.4/dist-packages/celery/worker/state.py", line 232, in _merge_revoked

self._merge_revoked_v3(d[b'zrevoked'])


 "/usr/lib/python3.4/shelve.py", line 113, in __getitem__

f = BytesIO(self.dict[key.encode(self.keyencoding)])
AttributeError: 'bytes' object has no attribute 'encode'
