public static void cleanStateBeforeTest(final EmbeddedKafkaCluster cluster,
                                            final int partitionCount,
                                            final int replicationCount,
                                            final String... topics) {
        try {
            cluster.deleteAllTopicsAndWait(DEFAULT_TIMEOUT);
            for (final String topic : topics) {
                cluster.createTopic(topic, partitionCount, replicationCount);
            }
        } catch (final InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
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