public static TableElements parse(final String schema, final TypeRegistry typeRegistry) {
    return new SchemaParser(typeRegistry).parse(schema);
  }
@Test
  public void shouldThrowOnReservedWord() {
    // Given:
    final String schema = "CREATE INTEGER";

    // Expect:
    // When:
    final Exception e = assertThrows(
        KsqlException.class,
        () -> parser.parse(schema)
    );

    // Then:
    assertThat(e.getMessage(), containsString("Error parsing schema \"CREATE INTEGER\" at 1:1: extraneous input 'CREATE' "));
  }