public void terminateCluster(final List<String> deleteTopicPatterns) {
    terminatePersistentQueries();
    deleteSinkTopics(deleteTopicPatterns);
    deleteTopics(managedTopics);
    ksqlEngine.close();
  }
@Test
  public void shouldNotCleanUpSchemaForNonSchemaInferenceSupportedTopic() throws Exception {
    // Given:
    givenTopicsExistInKafka("K_Foo");
    givenSinkTopicsExistInMetastore(FormatFactory.DELIMITED, "K_Foo");
    givenSchemasForTopicsExistInSchemaRegistry("K_Foo");

    // When:
    clusterTerminator.terminateCluster(ImmutableList.of("K_Foo"));

    // Then:
    verifySchemaNotDeletedForTopic("K_Foo");
  }