docs: void onConsumedPartition(ResultPartition partition) {
  		final ResultPartition previous;
  
  		LOG.debug("Received consume notification from {}.", partition);
  
  		synchronized (registeredPartitions) {
  			previous = registeredPartitions.remove(partition.getPartitionId());
  		}
  
  		// Release the partition if it was successfully removed
  		if (partition == previous) {
  			partition.release();
  
  			LOG.debug("Released {}.", partition);
  		}
  	}