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

Class AdminMetadataManager.AdminMetadataUpdater

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.clients.MetadataUpdater

Enclosing class:

AdminMetadataManager

public class AdminMetadataManager.AdminMetadataUpdater
extends Object
implements org.apache.kafka.clients.MetadataUpdater

Constructor Summary

Constructors

Constructor	Description
AdminMetadataUpdater()

Method Summary

Modifier and Type	Method	Description
void	close()
List<org.apache.kafka.common.Node>	fetchNodes()
void	handleFailedRequest(long now, Optional<org.apache.kafka.common.KafkaException> maybeFatalException)
void	handleServerDisconnect(long now, String destinationId, Optional<org.apache.kafka.common.errors.AuthenticationException> maybeFatalException)
void	handleSuccessfulResponse(org.apache.kafka.common.requests.RequestHeader requestHeader, long now, org.apache.kafka.common.requests.MetadataResponse metadataResponse)
boolean	isUpdateDue(long now)
long	maybeUpdate(long now)

Methods inherited from class java.lang.Object

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

Constructor Details

AdminMetadataUpdater

public AdminMetadataUpdater()

Method Details

fetchNodes

public List<org.apache.kafka.common.Node> fetchNodes()

Specified by:

fetchNodes in interface org.apache.kafka.clients.MetadataUpdater

isUpdateDue

public boolean isUpdateDue(long now)

Specified by:

isUpdateDue in interface org.apache.kafka.clients.MetadataUpdater

maybeUpdate

public long maybeUpdate(long now)

Specified by:

maybeUpdate in interface org.apache.kafka.clients.MetadataUpdater

handleServerDisconnect

public void handleServerDisconnect(long now,
 String destinationId,
 Optional<org.apache.kafka.common.errors.AuthenticationException> maybeFatalException)

Specified by:

handleServerDisconnect in interface org.apache.kafka.clients.MetadataUpdater

handleFailedRequest

public void handleFailedRequest(long now,
 Optional<org.apache.kafka.common.KafkaException> maybeFatalException)

Specified by:

handleFailedRequest in interface org.apache.kafka.clients.MetadataUpdater

handleSuccessfulResponse

public void handleSuccessfulResponse(org.apache.kafka.common.requests.RequestHeader requestHeader,
 long now,
 org.apache.kafka.common.requests.MetadataResponse metadataResponse)

Specified by:

handleSuccessfulResponse in interface org.apache.kafka.clients.MetadataUpdater

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.kafka.clients.MetadataUpdater