@InterfaceStability.Evolving public class ListTransactionsResult extends Object
Admin.listTransactions() call. The API of this class is evolving, see Admin for details.
| Modifier and Type | Method and Description |
|---|---|
KafkaFuture<Collection<TransactionListing>> | all()Get all transaction listings. |
KafkaFuture<Map<Integer,Collection<TransactionListing>>> | allByBrokerId()Get all transaction listings in a map which is keyed by the ID of respective broker that is currently managing them. |
KafkaFuture<Map<Integer,KafkaFuture<Collection<TransactionListing>>>> | byBrokerId()Get a future which returns a map containing the underlying listing future for each broker in the cluster. |
public KafkaFuture<Collection<TransactionListing>> all()
public KafkaFuture<Map<Integer,KafkaFuture<Collection<TransactionListing>>>> byBrokerId()
public KafkaFuture<Map<Integer,Collection<TransactionListing>>> allByBrokerId()