public static void quietlyCleanStateAfterTest(final EmbeddedKafkaCluster cluster, final KafkaStreams driver) {
        try {
            driver.cleanUp();
            cluster.deleteAllTopicsAndWait(DEFAULT_TIMEOUT);
        } catch (final RuntimeException | InterruptedException e) {
            LOG.warn("Ignoring failure to clean test state", 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