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

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

    // Then:
    assertThat(e, is(ERROR));
  }