code: def _spawn_kafka_consumer_thread(self):
          
          self.logger.debug("Spawn kafka consumer thread""")
          self._consumer_thread = Thread(target=self._consumer_loop)
          self._consumer_thread.setDaemon(True)
          self._consumer_thread.start()
docs: Spawns a kafka continuous consumer thread