io.confluent.security.store.kafka.clients

Interface Writer

All Known Implementing Classes:

DataplaneAuthWriter, KafkaAuthWriter

public interface Writer

Method Summary

Modifier and Type	Method and Description
boolean	ready() Returns true if this is the master writer and is ready to process requests
void	startWriter(int generationId) Starts master writer with the specified generation id.
void	stopWriter(Integer generationId) Stops this writer because a new master writer was elected.

Method Detail

startWriter

void startWriter(int generationId)

Starts master writer with the specified generation id. Writer generation is determined by the MetadataServiceCoordinator during writer election.

Parameters:

generationId - Generation id of writer

stopWriter

void stopWriter(Integer generationId)

Stops this writer because a new master writer was elected. If `generationId` is null, the writer is stopped regardless of the current generation of the writer. If not, the writer is stopped only if its current generation matches the provided value.

Parameters:

generationId - Generation id of writer being stopped or null to stop regardless of current writer generation

ready

boolean ready()

Returns true if this is the master writer and is ready to process requests