public KafkaFuture<Map<Integer, KafkaFuture<Collection<TransactionListing>>>> byBrokerId() {
        KafkaFutureImpl<Map<Integer, KafkaFuture<Collection<TransactionListing>>>> result = new KafkaFutureImpl<>();
        future.whenComplete((brokerFutures, exception) -> {
            if (brokerFutures != null) {
                Map<Integer, KafkaFuture<Collection<TransactionListing>>> brokerFuturesCopy =
                    new HashMap<>(brokerFutures.size());
                brokerFuturesCopy.putAll(brokerFutures);
                result.complete(brokerFuturesCopy);
            } else {
                result.completeExceptionally(exception);
            }
        });
        return result;
    }
Get a future which returns a map containing the underlying listing future for each broker
in the cluster. This is useful, for example, if a partial listing of transactions is
sufficient, or if you want more granular error details.

@return A future containing a map of futures by broker which complete individually when
        their respective transaction listings are available. The top-level future returned
        from this method may fail if the admin client is unable to lookup the available
        brokers in the cluster.
clients/src/main/java/org/apache/kafka/clients/admin/ListTransactionsResult.java