docs: public void init(SecorConfig config, OffsetTracker offsetTracker, FileRegistry fileRegistry,
                       UploadManager uploadManager, MessageReader messageReader,
                       ZookeeperConnector zookeeperConnector, MetricCollector metricCollector,
                       DeterministicUploadPolicyTracker deterministicUploadPolicyTracker) {
          mConfig = config;
          mOffsetTracker = offsetTracker;
          mFileRegistry = fileRegistry;
          mUploadManager = uploadManager;
          mMessageReader = messageReader;
          mZookeeperConnector = zookeeperConnector;
          mTopicFilter = mConfig.getKafkaTopicUploadAtMinuteMarkFilter();
          mMetricCollector = metricCollector;
          mDeterministicUploadPolicyTracker = deterministicUploadPolicyTracker;
          if (mConfig.getOffsetsStorage().equals(SecorConstants.KAFKA_OFFSETS_STORAGE_KAFKA)) {
              isOffsetsStorageKafka = true;
          }
      }