class KsqlEngine implements Closeable {

  public List<QueryMetadata> createQueries(final String queries) throws Exception {
    final MetaStore metaStoreCopy = metaStore.clone();
    return planQueries(
        parseQueries(
            queries,
            Collections.emptyMap(),
            metaStoreCopy
        ),
        new HashMap<>(),
        metaStoreCopy
    );
  }

  public  KsqlEngine(final KsqlConfig ksqlConfig, final KafkaTopicClient topicClient);
  public  KsqlEngine(
      final KsqlConfig ksqlConfig,
      final KafkaTopicClient topicClient,
      final SchemaRegistryClient schemaRegistryClient,
      final MetaStore metaStore
  );

}