public static <T> Deserializer<T> deserializer(final Class<T> clazz) {
    return new InternalTopicDeserializer<>(clazz);
  }
@Test
  public void shouldThrowSerializationExceptionOnSerializeError() {
    // When:
    assertThrows(
        SerializationException.class,
        () -> deserializer(Command.class).deserialize(
            "",
            "{abc".getBytes(defaultCharset())
        )
    );
  }