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

Class AdminMetadataManager

java.lang.Object

org.apache.kafka.clients.admin.internals.AdminMetadataManager

public class AdminMetadataManager
extends Object

Manages the metadata for KafkaAdminClient. This class is not thread-safe. It is only accessed from the AdminClient service thread (which also uses the NetworkClient).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	AdminMetadataManager.AdminMetadataUpdater

Constructor Summary

Constructors

Constructor	Description
AdminMetadataManager(org.apache.kafka.common.utils.LogContext logContext, long refreshBackoffMs, long metadataExpireMs, boolean usingBootstrapControllers)

Method Summary

Modifier and Type	Method	Description
void	clearController()
org.apache.kafka.common.Node	controller()
boolean	isReady()
long	metadataFetchDelayMs(long now)	Determine if the AdminClient should fetch new metadata.
org.apache.kafka.common.Node	nodeById(int nodeId)
void	requestUpdate()
void	transitionToUpdatePending(long now)	Transition into the UPDATE_PENDING state.
void	update(org.apache.kafka.common.Cluster cluster, long now)	Receive new metadata, and transition into the QUIESCENT state.
void	updateFailed(Throwable exception)
AdminMetadataManager.AdminMetadataUpdater	updater()
boolean	usingBootstrapControllers()

Methods inherited from class java.lang.Object

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

Constructor Details

AdminMetadataManager

public AdminMetadataManager(org.apache.kafka.common.utils.LogContext logContext,
 long refreshBackoffMs,
 long metadataExpireMs,
 boolean usingBootstrapControllers)

Method Details

usingBootstrapControllers

public boolean usingBootstrapControllers()

updater

public AdminMetadataManager.AdminMetadataUpdater updater()

isReady

public boolean isReady()

controller

public org.apache.kafka.common.Node controller()

nodeById

public org.apache.kafka.common.Node nodeById(int nodeId)

requestUpdate

public void requestUpdate()

clearController

public void clearController()

metadataFetchDelayMs

public long metadataFetchDelayMs(long now)

Determine if the AdminClient should fetch new metadata.

transitionToUpdatePending

public void transitionToUpdatePending(long now)

Transition into the UPDATE_PENDING state. Updates lastMetadataFetchAttemptMs.

updateFailed

public void updateFailed(Throwable exception)

update

public void update(org.apache.kafka.common.Cluster cluster,
 long now)

Receive new metadata, and transition into the QUIESCENT state. Updates lastMetadataUpdateMs, cluster, and authException.