Package 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	Description
KafkaGroupLeaderElector(SchemaRegistryConfig config, SchemaRegistryIdentity myIdentity, SchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method	Description
void	close()
void	init()
void	onAssigned(io.confluent.kafka.schemaregistry.leaderelector.kafka.SchemaRegistryProtocol.Assignment assignment, int generation)
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 Details

KafkaGroupLeaderElector

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

Throws:

SchemaRegistryInitializationException

Method Details

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(io.confluent.kafka.schemaregistry.leaderelector.kafka.SchemaRegistryProtocol.Assignment assignment,
 int generation)

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.