Package org.apache.kafka.clients.admin
Class FenceProducersResult
- java.lang.Object
-
- org.apache.kafka.clients.admin.FenceProducersResult
-
@Evolving public class FenceProducersResult extends Object
The result of theAdmin.fenceProducers(Collection)
call. The API of this class is evolving, seeAdmin
for details.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.
-
-
-
Method Detail
-
fencedProducers
public Map<String,KafkaFuture<Void>> fencedProducers()
Return a map from transactional ID to futures which can be used to check the status of individual fencings.
-
producerId
public KafkaFuture<Long> producerId(String transactionalId)
Returns a future that provides the producer ID generated while initializing the given transaction when the request completes.
-
epochId
public KafkaFuture<Short> epochId(String transactionalId)
Returns a future that provides the epoch ID generated while initializing the given transaction when the request completes.
-
all
public KafkaFuture<Void> all()
Return a future which succeeds only if all the producer fencings succeed.
-
-