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

Class StaticBrokerStrategy<K>

java.lang.Object
org.apache.kafka.clients.admin.internals.StaticBrokerStrategy<K>
All Implemented Interfaces:
AdminApiLookupStrategy<K>
public class StaticBrokerStrategy<K> extends Object implements AdminApiLookupStrategy<K>
This lookup strategy is used when we already know the destination broker ID and we have no need for an explicit lookup. By setting ApiRequestScope.destinationBrokerId() in the returned value for lookupScope(Object), the driver will skip the lookup.

  • Constructor Details

    • StaticBrokerStrategy

      public StaticBrokerStrategy(int brokerId)

  • Method Details

    • lookupScope

      public ApiRequestScope lookupScope(K key)
      Description copied from interface: AdminApiLookupStrategy
      Define the scope of a given key for lookup. Key lookups are complicated by the need to accommodate different batching mechanics. For example, a `Metadata` request supports arbitrary batching of topic partitions in order to discover partitions leaders. This can be supported by returning a single scope object for all keys. On the other hand, `FindCoordinator` requests only support lookup of a single key. This can be supported by returning a different scope object for each lookup key. Note that if the ApiRequestScope.destinationBrokerId() maps to a specific brokerId, then lookup will be skipped. See the use of StaticBrokerStrategy in DescribeProducersHandler for an example of this usage.
      Specified by:
      lookupScope in interface AdminApiLookupStrategy<K>
      Parameters:
      key - the lookup key
      Returns:
      request scope indicating how lookup requests can be batched together

    • buildRequest

      public org.apache.kafka.common.requests.AbstractRequest.Builder<?> buildRequest(Set<K> keys)
      Description copied from interface: AdminApiLookupStrategy
      Build the lookup request for a set of keys. The grouping of the keys is controlled through AdminApiLookupStrategy.lookupScope(Object). In other words, each set of keys that map to the same request scope object will be sent to this method.
      Specified by:
      buildRequest in interface AdminApiLookupStrategy<K>
      Parameters:
      keys - the set of keys that require lookup
      Returns:
      a builder for the lookup request

    • handleResponse

      public AdminApiLookupStrategy.LookupResult<K> handleResponse(Set<K> keys, org.apache.kafka.common.requests.AbstractResponse response)
      Description copied from interface: AdminApiLookupStrategy
      Callback that is invoked when a lookup request returns successfully. The handler should parse the response, check for errors, and return a result indicating which keys were mapped to a brokerId successfully and which keys received a fatal error (e.g. a topic authorization failure). Note that keys which receive a retriable error should be left out of the result. They will be retried automatically. For example, if the response of `FindCoordinator` request indicates an unavailable coordinator, then the key should be left out of the result so that the request will be retried.
      Specified by:
      handleResponse in interface AdminApiLookupStrategy<K>
      Parameters:
      keys - the set of keys from the associated request
      response - the response received from the broker
      Returns:
      a result indicating which keys mapped successfully to a brokerId and which encountered a fatal error