code: public void completeExceptionally(long id, Throwable throwable, int topologyId) {
        BaseAckTarget ackTarget = collectorMap.get(id);
        if (ackTarget != null) {
           ackTarget.completeExceptionally(throwable, topologyId);
        }
     }
docs: Acknowledges an exception during the operation execution.
  <p>
  The collector is completed without waiting any further acknowledges.
  
  @param id         the id from {@link CommandInvocationId#getId()}.
  @param throwable  the {@link Throwable}.
  @param topologyId the topology id.