docs: public void applyPolicy(boolean forceUpload) throws Exception {
          Collection<TopicPartition> topicPartitions = mFileRegistry.getTopicPartitions();
          for (TopicPartition topicPartition : topicPartitions) {
              checkTopicPartition(topicPartition, forceUpload);
          }
      }