Package org.apache.kafka.clients.admin.internals
package org.apache.kafka.clients.admin.internals
-
ClassDescriptionAdminApiDriver<K,
V> The `KafkaAdminClient`'s internal `Call` primitive is not a good fit for multi-stage request workflows such as we see with the group coordinator APIs or any request which needs to be sent to a partition leader.This is a helper class which helps us to map requests that need to be sent to the internal `Call` implementation that is used internally inKafkaAdminClient.AdminApiFuture<K,V> This class can be used when the set of keys is known ahead of time.AdminApiHandler<K,V> AnAdminApiHandlerthat will group multiple keys into a single request when possible.AnAdminApiHandlerthat will create one request per key, not performing any grouping based on the targeted broker.Manages the metadata for KafkaAdminClient.This class is used for use cases which require requests to be sent to all brokers in the cluster.This interface is used byAdminApiDriverto bridge the gap to the internal `NodeProvider` defined inKafkaAdminClient.Base driver implementation for APIs which target partition leaders.This lookup strategy is used when we already know the destination broker ID and we have no need for an explicit lookup.