@Override
  public <T extends Statement> ConfiguredStatement<T> inject(
      final ConfiguredStatement<T> statement
  ) {
    return inject(statement, new TopicProperties.Builder());
  }
@Test
  public void shouldHaveCleanupPolicyCompactCreateTable() {
    // Given:
    givenStatement("CREATE TABLE foo (FOO VARCHAR) WITH (kafka_topic='topic', partitions=1);");

    // When:
    final CreateSource createSource = ((CreateSource) injector.inject(statement, builder).getStatement());

    // Then:
    final CreateSourceProperties props = createSource.getProperties();
    assertThat(props.getCleanupPolicy(), is(Optional.of(TopicConfig.CLEANUP_POLICY_COMPACT)));
  }