@Override
  public T deserialize(final String topic, final byte[] bytes) {
    return tryDeserialize(topic, bytes).get();
  }
@Test
  public void shouldLogOnException() {
    // Given:
    when(delegate.deserialize(any(), any())).thenThrow(ERROR);

    // When:
    assertThrows(
        RuntimeException.class,
        () -> deserializer.deserialize("t", SOME_BYTES)
    );

    // Then:
    verify(processingLogger).error(new DeserializationError(ERROR, Optional.of(SOME_BYTES), "t", false));
  }