public void terminateCluster(final List<String> deleteTopicPatterns) {
    terminatePersistentQueries();
    deleteSinkTopics(deleteTopicPatterns);
    deleteTopics(managedTopics);
    ksqlEngine.close();
  }
@Test
  public void shouldNotCleanUpSchemaForNonSinkTopic() throws Exception {
    // Given:
    givenTopicsExistInKafka("bar");
    givenNonSinkTopicsExistInMetastore("bar");
    givenSchemasForTopicsExistInSchemaRegistry("bar");

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

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