@Override
  public SchemaResult getValueSchema(
      final Optional<String> topicName,
      final Optional<Integer> schemaId,
      final FormatInfo expectedFormat,
      final SerdeFeatures serdeFeatures
  ) {
    return getSchema(topicName, schemaId, expectedFormat, serdeFeatures, false);
  }
@Test
  public void shouldThrowFromGetValueSchemaOnOtherRestExceptions() throws Exception {
    // Given:
    when(srClient.getLatestSchemaMetadata(any()))
        .thenThrow(new RestClientException("failure", 1, 1));

    // When:
    final Exception e = assertThrows(
        KsqlException.class,
        () -> supplier.getValueSchema(Optional.of(TOPIC_NAME),
            Optional.empty(), expectedFormat, SerdeFeatures.of())
    );

    // Then:
    assertThat(e.getMessage(), containsString("Schema registry fetch for topic "
        + "value request failed for topic: " + TOPIC_NAME));
  }