@Override
  public <T extends Statement> ConfiguredStatement<T> inject(
      final ConfiguredStatement<T> statement
  ) {
    return inject(statement, new TopicProperties.Builder());
  }
@Test
  public void shouldThrowIfRetentionConfigPresentInCreateTable() {
    // Given:
    givenStatement("CREATE TABLE foo_bar (FOO STRING PRIMARY KEY, BAR STRING) WITH (kafka_topic='doesntexist', partitions=2, format='avro', retention_ms=30000);");

    // When:
    final Exception e = assertThrows(
        KsqlException.class,
        () -> injector.inject(statement, builder)
    );

    // Then:
    assertThat(
        e.getMessage(),
        containsString("Invalid config variable in the WITH clause: RETENTION_MS."
            + " Non-windowed tables do not support retention."));
  }