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) |
protected org.apache.kafka.clients.KafkaClient |
createKafkaClient(org.apache.kafka.clients.consumer.ConsumerConfig coordinatorConfig,
org.apache.kafka.clients.Metadata metadata,
org.apache.kafka.common.utils.Time time,
org.apache.kafka.common.utils.LogContext logContext) |
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.
|
protected void |
onWriterResigned() |
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
protected void onWriterResigned()
public void close(Duration closeTimeout)
protected org.apache.kafka.clients.KafkaClient createKafkaClient(org.apache.kafka.clients.consumer.ConsumerConfig coordinatorConfig, org.apache.kafka.clients.Metadata metadata, org.apache.kafka.common.utils.Time time, org.apache.kafka.common.utils.LogContext logContext)