docs: static DistributerException loggedDistributerException(Throwable cause, String format, Object...args) {
          Optional<DistributerException> causeFor = DistributerException.isCauseFor(cause);
          if (causeFor.isPresent()) {
              return causeFor.get();
          }
          String msg = String.format(format, args);
          if (cause != null) {
              LOG.error(msg, cause);
              return new DistributerException(msg, cause);
          } else {
              LOG.error(msg);
              return new DistributerException(msg);
          }
      }