@Test
public void testStorePartitions() throws Exception {

    File baseDir = Files.createTempDirectory("test").toFile();
    try {
        StreamsConfig config = createConfig(baseDir);
        StandbyTask task = new StandbyTask(taskId, applicationId, topicPartitions, topology, consumer, restoreStateConsumer, config, null);
        assertEquals(Utils.mkSet(partition2), new HashSet<>(task.changeLogPartitions()));
    } finally {
        Utils.delete(baseDir);
    }
}