@InterfaceStability.Evolving public class FenceProducersResult extends Object
Admin.fenceProducers(Collection) call. The API of this class is evolving, see Admin for details.| Modifier and Type | Method and Description |
|---|---|
KafkaFuture<Void> | all()Return a future which succeeds only if all the producer fencings succeed. |
KafkaFuture<Short> | epochId(String transactionalId)Returns a future that provides the epoch ID generated while initializing the given transaction when the request completes. |
Map<String,KafkaFuture<Void>> | fencedProducers()Return a map from transactional ID to futures which can be used to check the status of individual fencings. |
KafkaFuture<Long> | producerId(String transactionalId)Returns a future that provides the producer ID generated while initializing the given transaction when the request completes. |
public Map<String,KafkaFuture<Void>> fencedProducers()
public KafkaFuture<Long> producerId(String transactionalId)
public KafkaFuture<Short> epochId(String transactionalId)
public KafkaFuture<Void> all()