Page History

package org.apache.kafka.clients.admin;

/**
 * The result of the {@link Admin#fenceProducers(Collection)} call.
 *
 * The API of this class is evolving, see {@link Admin} for details.
 */
@InterfaceStability.Evolving
public class FenceProducersResult {

    /**
     * Return a map from transactional ID to futures which can be used to check the status of
     * individual fencings.
     */
    public Map<String, KafkaFuture<Void>> fencedProducers() {
		// Implementation goes here
    }

    	/**
	 * Returns a future *that Returnprovides athe futureproducer whichID succeedsgenerated onlywhile if allinitializing the producergiven fencingstransaction succeed.
when the request  completes.
	 */
    	public KafkaFuture<Void>KafkaFuture<Long> allproducerId(String transactionalId) {
		// Implementation goes here
	}

	/**
 	 * Returns a future that provides  }

}

the epoch ID generated while initializing the given transaction when the request completes.
	 */
	public KafkaFuture<Short> epochId(String transactionalId) {
		// Implementation goes here
	}

    /**
     * Return a future which succeeds only if all the producer fencings succeed.
     */
    public KafkaFuture<Void> all() {
		// Implementation goes here
    }

}