MetadataUpdater

MetadataUpdater Contract

package org.apache.kafka.clients;

interface MetadataUpdater {
  List<Node> fetchNodes();
  void handleDisconnection(String destination);
  void handleAuthenticationFailure(AuthenticationException exception);
  void handleCompletedMetadataResponse(RequestHeader requestHeader, long now, MetadataResponse metadataResponse);
  boolean isUpdateDue(long now);
  long maybeUpdate(long now);
  void requestUpdate();
}
Table 1. MetadataUpdater Contract (in alphabetical order)
Method Description

maybeUpdate

Starts a cluster metadata update if needed and possible.

Used exclusively when NetworkClient is requested to read and write to sockets.

requestUpdate

handleAuthenticationFailure

handleCompletedMetadataResponse

Used exclusively when NetworkClient handles completed receives

results matching ""

    No results matching ""