docs: def thread(self):
          """
          Start a thread for this consumer.
          """
          log.info('@{}.thread starting'.format(self.__class__.__name__))
          thread = threading.Thread(target=thread_wrapper(self.consume), args=())
          thread.daemon = True
          thread.start()