public List<QueryMetadata> sql(final String sql) {
    return sql(sql, Collections.emptyMap());
  }
@Test
  public void shouldInferTopicWithValidArgs() {
    // Given:
    when(schemaInjector.inject(any())).thenAnswer(inv -> inv.getArgument(0));

    // When:
    ksqlContext.sql("Some SQL", SOME_PROPERTIES);

    // Then:
    verify(topicInjector, times(2) /* once to validate, once to execute */)
        .inject(CFG_STMT_0);
  }