public class MetadataNodeManager extends Object implements MetadataServiceRebalanceListener
Constructor and Description |
---|
MetadataNodeManager(Collection<URL> nodeUrls,
KafkaStoreConfig config,
Writer metadataWriter,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
Collection<URL> |
activeNodeUrls(String protocol) |
void |
close(Duration closeTimeout) |
boolean |
isMasterWriter() |
URL |
masterWriterUrl(String protocol) |
void |
onAssigned(MetadataServiceAssignment assignment,
int generationId)
Assignment completion notification generated when rebalance completes.
|
void |
onRevoked(int generationId)
Assignment revocation notification generated when rebalance commences.
|
void |
onWriterResigned(int generationId)
Writer resignation notification generated by the writer when an error
is encountered, cache refresh times out or a generation marker with
newer generation is is received.
|
CompletionStage<Void> |
start() |
public MetadataNodeManager(Collection<URL> nodeUrls, KafkaStoreConfig config, Writer metadataWriter, org.apache.kafka.common.utils.Time time)
public CompletionStage<Void> start()
public boolean isMasterWriter()
public Collection<URL> activeNodeUrls(String protocol)
public void onAssigned(MetadataServiceAssignment assignment, int generationId)
MetadataServiceRebalanceListener
onAssigned
in interface MetadataServiceRebalanceListener
public void onRevoked(int generationId)
MetadataServiceRebalanceListener
onRevoked
in interface MetadataServiceRebalanceListener
public void onWriterResigned(int generationId)
MetadataServiceRebalanceListener
onWriterResigned
in interface MetadataServiceRebalanceListener
public void close(Duration closeTimeout)