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

Class PartitionLeaderStrategy

java.lang.Object
org.apache.kafka.clients.admin.internals.PartitionLeaderStrategy
All Implemented Interfaces:
AdminApiLookupStrategy<org.apache.kafka.common.TopicPartition>
public class PartitionLeaderStrategy extends Object implements AdminApiLookupStrategy<org.apache.kafka.common.TopicPartition>
Base driver implementation for APIs which target partition leaders.

  • Constructor Details

    • PartitionLeaderStrategy

      public PartitionLeaderStrategy(org.apache.kafka.common.utils.LogContext logContext)

    • PartitionLeaderStrategy

      public PartitionLeaderStrategy(org.apache.kafka.common.utils.LogContext logContext, boolean tolerateUnknownTopics)

  • Method Details

    • lookupScope

      public ApiRequestScope lookupScope(org.apache.kafka.common.TopicPartition 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<org.apache.kafka.common.TopicPartition>
      Parameters:
      key - the lookup key
      Returns:
      request scope indicating how lookup requests can be batched together

    • buildRequest

      public org.apache.kafka.common.requests.MetadataRequest.Builder buildRequest(Set<org.apache.kafka.common.TopicPartition> partitions)
      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<org.apache.kafka.common.TopicPartition>
      Parameters:
      partitions - the set of keys that require lookup
      Returns:
      a builder for the lookup request

    • handleResponse

      public AdminApiLookupStrategy.LookupResult<org.apache.kafka.common.TopicPartition> handleResponse(Set<org.apache.kafka.common.TopicPartition> requestPartitions, org.apache.kafka.common.requests.AbstractResponse abstractResponse)
      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<org.apache.kafka.common.TopicPartition>
      Parameters:
      requestPartitions - the set of keys from the associated request
      abstractResponse - the response received from the broker
      Returns:
      a result indicating which keys mapped successfully to a brokerId and which encountered a fatal error