public List<QueryMetadata> sql(final String sql) {
    return sql(sql, Collections.emptyMap());
  }
@Test
  public void shouldThrowIfParseFails() {
    // Given:
    when(ksqlEngine.parse(any()))
        .thenThrow(new KsqlException("Bad tings happen"));

    // When:
    final Exception e = assertThrows(
        KsqlException.class,
        () -> ksqlContext.sql("Some SQL", SOME_PROPERTIES)
    );

    // Then:
    assertThat(e.getMessage(), containsString(
        "Bad tings happen"));
  }