def set_process_name(self):
"""Setup process name for consumer to include topic and
partitions to improve debuggability.
"""
process_name = '%s-%s-%s' % (getproctitle(), self.topic.decode(), self.partitions)
setproctitle(process_name)
评论列表
文章目录