@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 shouldReturnErrorFromGetValueSchemaIfCanNotConvertToConnectSchema() {
    // Given:
    when(schemaTranslator.toColumns(any(), any(), anyBoolean()))
        .thenThrow(new RuntimeException("it went boom"));

    // When:
    final SchemaResult result = supplier
        .getValueSchema(Optional.of(TOPIC_NAME), Optional.empty(), expectedFormat, SerdeFeatures.of());

    // Then:
    assertThat(result.schemaAndId, is(Optional.empty()));
    assertThat(result.failureReason.get().getMessage(), containsString(
        "Unable to verify if the value schema for topic: some-topic is compatible with ksqlDB."));
    assertThat(result.failureReason.get().getMessage(), containsString(
        "it went boom"));
    assertThat(result.failureReason.get().getMessage(), containsString(AVRO_SCHEMA));
  }