public Type parse(final String schema) {
    try {
      final TypeContext typeContext = parseTypeContext(schema);
      return getType(typeContext);
    } catch (final ParsingException e) {
      throw new KsqlStatementException(
          "Failed to parse schema",
          "Failed to parse: " + schema,
          schema,
          KsqlStatementException.Problem.STATEMENT,
          e
      );
    }
  }
@Test
  public void shouldThrowOnNonIntegerScale() {
    // Given:
    final String schemaString = "DECIMAL(1, 1.1)";

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

    // Then:
    assertThat(e.getMessage(), containsString(
        "Value must be integer for command: DECIMAL(SCALE)"
    ));
  }