public static ConnectToSqlTypeConverter connectToSqlConverter() {
    return CONNECT_TO_SQL_CONVERTER;
  }
@Test
  public void shouldThrowOnUnsupportedConnectSchemaType() {
    // Given:
    final Schema unsupported = SchemaBuilder.int8().build();

    // When:
    final Exception e = assertThrows(
        KsqlException.class,
        () -> SchemaConverters.connectToSqlConverter().toSqlType(unsupported)
    );

    // Then:
    assertThat(e.getMessage(), containsString("Unexpected schema type: Schema{INT8}"));
  }