Package org.apache.kafka.clients.admin.internals

Class AllBrokersStrategy.AllBrokersFuture<V>

java.lang.Object

org.apache.kafka.clients.admin.internals.AllBrokersStrategy.AllBrokersFuture<V>

All Implemented Interfaces:

AdminApiFuture<AllBrokersStrategy.BrokerKey,V>

Enclosing class:

AllBrokersStrategy

public static class AllBrokersStrategy.AllBrokersFuture<V>
extends Object
implements AdminApiFuture<AllBrokersStrategy.BrokerKey,V>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.kafka.clients.admin.internals.AdminApiFuture

AdminApiFuture.SimpleAdminApiFuture<K,V>

Constructor Summary

Constructors

Constructor	Description
AllBrokersFuture()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.common.internals.KafkaFutureImpl<Map<Integer,org.apache.kafka.common.internals.KafkaFutureImpl<V>>>	all()
void	complete(Map<AllBrokersStrategy.BrokerKey,V> values)	Complete the futures associated with the given keys.
void	completeExceptionally(Map<AllBrokersStrategy.BrokerKey,Throwable> errors)	Complete the futures associated with the given keys exceptionally.
void	completeLookup(Map<AllBrokersStrategy.BrokerKey,Integer> brokerMapping)	Invoked when lookup of a set of keys succeeds.
void	completeLookupExceptionally(Map<AllBrokersStrategy.BrokerKey,Throwable> lookupErrors)	Invoked when lookup fails with a fatal error on a set of keys.
Set<AllBrokersStrategy.BrokerKey>	lookupKeys()	The initial set of lookup keys.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AllBrokersFuture

public AllBrokersFuture()

Method Details

lookupKeys

public Set<AllBrokersStrategy.BrokerKey> lookupKeys()

Description copied from interface: AdminApiFuture

The initial set of lookup keys. Although this will usually match the fulfillment keys, it does not necessarily have to. For example, in the case of AllBrokersStrategy.AllBrokersFuture, we use the lookup phase in order to discover the set of keys that will be searched during the fulfillment phase.

Specified by:

lookupKeys in interface AdminApiFuture<AllBrokersStrategy.BrokerKey,V>

Returns:

non-empty set of initial lookup keys

completeLookup

public void completeLookup(Map<AllBrokersStrategy.BrokerKey,Integer> brokerMapping)

Description copied from interface: AdminApiFuture

Invoked when lookup of a set of keys succeeds.

Specified by:

completeLookup in interface AdminApiFuture<AllBrokersStrategy.BrokerKey,V>

Parameters:

brokerMapping - the discovered mapping from key to the respective brokerId that will handle the fulfillment request

completeLookupExceptionally

public void completeLookupExceptionally(Map<AllBrokersStrategy.BrokerKey,Throwable> lookupErrors)

Description copied from interface: AdminApiFuture

Invoked when lookup fails with a fatal error on a set of keys.

Specified by:

completeLookupExceptionally in interface AdminApiFuture<AllBrokersStrategy.BrokerKey,V>

Parameters:

lookupErrors - the set of keys that failed lookup with their respective errors

complete

public void complete(Map<AllBrokersStrategy.BrokerKey,V> values)

Description copied from interface: AdminApiFuture

Complete the futures associated with the given keys.

Specified by:

complete in interface AdminApiFuture<AllBrokersStrategy.BrokerKey,V>

Parameters:

values - the completed keys with their respective values

completeExceptionally

public void completeExceptionally(Map<AllBrokersStrategy.BrokerKey,Throwable> errors)

Description copied from interface: AdminApiFuture

Complete the futures associated with the given keys exceptionally.

Specified by:

completeExceptionally in interface AdminApiFuture<AllBrokersStrategy.BrokerKey,V>

Parameters:

errors - the failed keys with their respective errors

all

public org.apache.kafka.common.internals.KafkaFutureImpl<Map<Integer,org.apache.kafka.common.internals.KafkaFutureImpl<V>>> all()