io.confluent.kafka.schemaregistry.leaderelector.kafka

Class KafkaGroupLeaderElector

java.lang.Object

io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector

All Implemented Interfaces:

LeaderElector

public class KafkaGroupLeaderElector
extends Object
implements LeaderElector

Constructor Summary

Constructors

Constructor and Description
KafkaGroupLeaderElector(SchemaRegistryConfig config, SchemaRegistryIdentity myIdentity, KafkaSchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method and Description
void	close()
void	init()
void	onAssigned(SchemaRegistryProtocol.Assignment assignment, int generation) Invoked when a new assignment is created by joining the schema registry group.
void	onRevoked() This is a no-op during leader election if stickyLeaderElection is enabled as we're not revoking previous leader assignment.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaGroupLeaderElector

public KafkaGroupLeaderElector(SchemaRegistryConfig config,
                               SchemaRegistryIdentity myIdentity,
                               KafkaSchemaRegistry schemaRegistry)
                        throws SchemaRegistryInitializationException

Throws:

SchemaRegistryInitializationException

Method Detail

init

public void init()
          throws SchemaRegistryTimeoutException,
                 SchemaRegistryStoreException

Specified by:

init in interface LeaderElector

Throws:

SchemaRegistryTimeoutException

SchemaRegistryStoreException

close

public void close()

Specified by:

close in interface LeaderElector

onAssigned

public void onAssigned(SchemaRegistryProtocol.Assignment assignment,
                       int generation)

Invoked when a new assignment is created by joining the schema registry group. This is invoked for both successful and unsuccessful assignments.

onRevoked

public void onRevoked()

This is a no-op during leader election if stickyLeaderElection is enabled as we're not revoking previous leader assignment. The expectation is that the sync group response will notify the group members if there's a leadership change.