Uses of Class
io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity
Packages that use SchemaRegistryIdentity
Package
Description
-
Uses of SchemaRegistryIdentity in io.confluent.kafka.schemaregistry.leaderelector.kafka
Constructors in io.confluent.kafka.schemaregistry.leaderelector.kafka with parameters of type SchemaRegistryIdentityModifierConstructorDescriptionKafkaGroupLeaderElector(SchemaRegistryConfig config, SchemaRegistryIdentity myIdentity, SchemaRegistry schemaRegistry) -
Uses of SchemaRegistryIdentity in io.confluent.kafka.schemaregistry.storage
Methods in io.confluent.kafka.schemaregistry.storage that return SchemaRegistryIdentityModifier and TypeMethodDescriptionstatic SchemaRegistryIdentitystatic SchemaRegistryIdentitySchemaRegistryIdentity.fromJson(ByteBuffer json) KafkaSchemaRegistry.leaderIdentity()Return the identity of the SchemaRegistry that this instance thinks is current leader.default SchemaRegistryIdentitySchemaRegistry.leaderIdentity()KafkaSchemaRegistry.myIdentity()Return json data encoding basic information about this SchemaRegistry instance, such as host, port, etc.SchemaRegistry.myIdentity()Methods in io.confluent.kafka.schemaregistry.storage with parameters of type SchemaRegistryIdentityModifier and TypeMethodDescriptionvoidKafkaSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader) 'Inform' this SchemaRegistry instance which SchemaRegistry is the current leader.voidLeaderAwareSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader) default voidSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader)