@Override
  public <T extends Statement> ConfiguredStatement<T> inject(
      final ConfiguredStatement<T> statement
  ) {
    return inject(statement, new TopicProperties.Builder());
  }
@Test
  public void shouldHaveSuperUsefulErrorMessageIfCreateWithNoPartitions() {
    // Given:
    givenStatement("CREATE STREAM foo (FOO STRING) WITH (value_format='avro', kafka_topic='doesntexist');");

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

    // Then:
    assertThat(e.getMessage(), containsString(
        "Topic 'doesntexist' does not exist. If you want to create a new topic for the "
        + "stream/table please re-run the statement providing the required 'PARTITIONS' "
        + "configuration in the WITH clause (and optionally 'REPLICAS'). For example: "
        + "CREATE STREAM FOO (FOO STRING) "
        + "WITH (KAFKA_TOPIC='doesntexist', PARTITIONS=2, VALUE_FORMAT='avro');"));
  }