code: def close(self):
          
          self.logger.info("Closing Rest Service")
          self.closed = True
  
          # close threads
          self._close_thread(self._redis_thread, "Redis setup")
          self._close_thread(self._heartbeat_thread, "Heartbeat")
          self._close_thread(self._kafka_thread, "Kafka setup")
          self._close_thread(self._consumer_thread, "Consumer")
  
          # close kafka
          if self.consumer is not None:
              self.logger.debug("Closing kafka consumer")
              self.consumer.close()
          if self.producer is not None:
              self.logger.debug("Closing kafka producer")
              self.producer.close(timeout=10)
docs: Cleans up anything from the process