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

Interface ApiRequestScope

public interface ApiRequestScope
This interface is used by AdminApiDriver to bridge the gap to the internal `NodeProvider` defined in KafkaAdminClient. However, a request scope is more than just a target broker specification. It also provides a way to group key lookups according to different batching mechanics. See AdminApiLookupStrategy.lookupScope(Object) for more detail.

  • Method Summary

    Modifier and Type
    Method
    Description
    default OptionalInt
    destinationBrokerId()
    Get the target broker ID that a request is intended for or empty if the request can be sent to any broker.

  • Method Details

    • destinationBrokerId

      default OptionalInt destinationBrokerId()
      Get the target broker ID that a request is intended for or empty if the request can be sent to any broker. Note that if the destination broker ID is present in the ApiRequestScope returned by AdminApiLookupStrategy.lookupScope(Object), then no lookup will be attempted.
      Returns:
      optional broker ID