@Override
  public <T extends Statement> ConfiguredStatement<T> inject(
      final ConfiguredStatement<T> statement
  ) {
    return inject(statement, new TopicProperties.Builder());
  }
@Test
  public void shouldThrowIfCleanupPolicyConfigPresentInCreateTableAs() {
    // Given:
    givenStatement("CREATE TABLE foo_bar WITH (kafka_topic='foo', partitions=1, cleanup_policy='whatever') AS SELECT * FROM SOURCE;");

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

    // Then:
    assertThat(
        e.getMessage(),
        containsString("Invalid config variable in the WITH clause: CLEANUP_POLICY.\n"
            + "The CLEANUP_POLICY config is automatically inferred based on the type of source (STREAM or TABLE).\n"
            + "Users can't set the CLEANUP_POLICY config manually."));
  }