<T> Serde<T> wrapInLoggingSerde(
          final Serde<T> formatSerde,
          final String loggerNamePrefix,
          final ProcessingLogContext processingLogContext
  ) {
    return wrapInLoggingSerde(
        formatSerde,
        loggerNamePrefix,
        processingLogContext,
        Optional.empty()
    );
  }
@Test
  public void shouldWrapSerializerWithLoggingSerializer() {
    // Given:
    final Serde<String> result = serdeFactory
        .wrapInLoggingSerde(formatSerde, "prefix", processingLogContext);

    // Then:
    assertThrows(
        RuntimeException.class,
        () -> result.serializer().serialize(
            "topicName",
            "this call will cause error to be logged"
        )
    );

    verify(processingLoggerWithoutQueryId).error(any());
  }