class ProcessorStateManager {

    public static FileLock lockStateDirectory(File stateDir) throws IOException {
        return lockStateDirectory(stateDir, 0);
    }

    public  ProcessorStateManager(String applicationId, int defaultPartition, Collection<TopicPartition> sources, File baseDir, Consumer<byte[], byte[]> restoreConsumer, boolean isStandby);

}