code: def consumer_shutdown_task(processor, check_point_tracker):
      
      exception = None
      try:
          processor.shutdown(check_point_tracker)
      except Exception as e:
          print(e)
          exception = None
  
      try:
          check_point_tracker.get_check_point()
      except Exception:
          logger.error('Failed to flush check point', exc_info=True)
  
      return TaskResult(exception)
docs: :param processor:
      :param check_point_tracker:
      :return: