class LoggingDeserializer implements Deserializer<T> {

  @Override
  public T deserialize(final String topic, final byte[] bytes) {
    return tryDeserialize(topic, bytes).get();
  }

  public  LoggingDeserializer(
      final Deserializer<T> delegate,
      final ProcessingLogger processingLogger
  );

}