| Package | Description |
|---|---|
| io.confluent.kafka.schemaregistry.leaderelector.kafka | |
| io.confluent.kafka.schemaregistry.storage |
| Constructor and Description |
|---|
KafkaGroupLeaderElector(SchemaRegistryConfig config,
SchemaRegistryIdentity myIdentity,
KafkaSchemaRegistry schemaRegistry) |
| Modifier and Type | Method and Description |
|---|---|
static SchemaRegistryIdentity |
SchemaRegistryIdentity.fromJson(ByteBuffer json) |
static SchemaRegistryIdentity |
SchemaRegistryIdentity.fromJson(String json) |
SchemaRegistryIdentity |
KafkaSchemaRegistry.leaderIdentity()
Return the identity of the SchemaRegistry that this instance thinks is current leader.
|
SchemaRegistryIdentity |
KafkaSchemaRegistry.myIdentity()
Return json data encoding basic information about this SchemaRegistry instance, such as
host, port, etc.
|
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader)
'Inform' this SchemaRegistry instance which SchemaRegistry is the current leader.
|
void |
LeaderAwareSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader) |
Copyright © 2026 Confluent, Inc.. All rights reserved.