public static void cleanStateBeforeTest(final EmbeddedKafkaCluster cluster,
                                            final int partitionCount,
                                            final String... topics) {
        cleanStateBeforeTest(cluster, partitionCount, 1, topics);
    }
Removes local state stores. Useful to reset state in-between integration test runs.

@param streamsConfigurations Streams configuration settings
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java