io.confluent.security.store.kafka.coordinator

Class MetadataNodeManager

java.lang.Object

io.confluent.security.store.kafka.coordinator.MetadataNodeManager

All Implemented Interfaces:

MetadataServiceRebalanceListener

public class MetadataNodeManager
extends Object
implements MetadataServiceRebalanceListener

Node manager for Metadata Service. A Kafka group coordinator is used to manage active nodes and elect a single master writer.

Constructor Summary

Constructors

Constructor and Description
MetadataNodeManager(Collection<URL> nodeUrls, KafkaStoreConfig config, Writer metadataWriter, org.apache.kafka.common.utils.Time time)

Method Summary

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataNodeManager

public MetadataNodeManager(Collection<URL> nodeUrls,
                           KafkaStoreConfig config,
                           Writer metadataWriter,
                           org.apache.kafka.common.utils.Time time)

Method Detail

start

public CompletionStage<Void> start()

isMasterWriter

public boolean isMasterWriter()

masterWriterUrl

public URL masterWriterUrl(String protocol)

activeNodeUrls

public Collection<URL> activeNodeUrls(String protocol)

onAssigned

public void onAssigned(MetadataServiceAssignment assignment,
                       int generationId)

Description copied from interface: MetadataServiceRebalanceListener

Assignment completion notification generated when rebalance completes.

Specified by:

onAssigned in interface MetadataServiceRebalanceListener

onRevoked

public void onRevoked(int generationId)

Description copied from interface: MetadataServiceRebalanceListener

Assignment revocation notification generated when rebalance commences.

Specified by:

onRevoked in interface MetadataServiceRebalanceListener

onWriterResigned

public void onWriterResigned(int generationId)

Description copied from interface: MetadataServiceRebalanceListener

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. This is used to trigger re-election.

Specified by:

onWriterResigned in interface MetadataServiceRebalanceListener

onWriterResigned

protected void onWriterResigned()

close

public void close(Duration closeTimeout)

createKafkaClient

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)