| Package | Description |
|---|---|
| io.confluent.kafka.schemaregistry.id | |
| io.confluent.kafka.schemaregistry.storage |
| Modifier and Type | Method and Description |
|---|---|
void |
IdGenerator.schemaRegistered(SchemaKey schemaKey,
SchemaValue schemaValue)
Callback method that is invoked when a schema is registered.
|
void |
IncrementalIdGenerator.schemaRegistered(SchemaKey schemaKey,
SchemaValue schemaValue) |
| Modifier and Type | Method and Description |
|---|---|
SchemaKey |
SchemaIdAndSubjects.findAny(Predicate<SchemaKey> filter) |
SchemaKey |
InMemoryCache.schemaKeyById(Integer id,
String subject) |
SchemaKey |
LookupCache.schemaKeyById(Integer id,
String subject)
Provides the
SchemaKey for the provided schema id. |
SchemaKey |
SchemaValue.toKey() |
| Modifier and Type | Method and Description |
|---|---|
Iterator<SchemaKey> |
KafkaSchemaRegistry.getAllVersions(String subject,
LookupFilter filter) |
Iterator<SchemaKey> |
SchemaRegistry.getAllVersions(String subject,
LookupFilter filter) |
| Modifier and Type | Method and Description |
|---|---|
protected SchemaValue |
KafkaSchemaRegistry.getSchemaValue(SchemaKey key) |
Set<Integer> |
InMemoryCache.referencesSchema(SchemaKey schema) |
Set<Integer> |
LookupCache.referencesSchema(SchemaKey schema)
Returns schemas that reference the given schema.
|
void |
InMemoryCache.schemaDeleted(SchemaKey schemaKey,
SchemaValue schemaValue,
SchemaValue oldSchemaValue) |
void |
LookupCache.schemaDeleted(SchemaKey schemaKey,
SchemaValue schemaValue,
SchemaValue oldSchemaValue)
Callback that is invoked when a schema is deleted.
|
void |
InMemoryCache.schemaRegistered(SchemaKey schemaKey,
SchemaValue schemaValue,
SchemaValue oldSchemaValue) |
void |
LookupCache.schemaRegistered(SchemaKey schemaKey,
SchemaValue schemaValue,
SchemaValue oldSchemaValue)
Callback that is invoked when a schema is registered.
|
void |
InMemoryCache.schemaTombstoned(SchemaKey schemaKey,
SchemaValue schemaValue) |
void |
LookupCache.schemaTombstoned(SchemaKey schemaKey,
SchemaValue schemaValue)
Callback that is invoked when a schema is tombstoned.
|
| Modifier and Type | Method and Description |
|---|---|
SchemaKey |
SchemaIdAndSubjects.findAny(Predicate<SchemaKey> filter) |
List<String> |
KafkaSchemaRegistry.isCompatible(String subject,
Schema newSchema,
List<SchemaKey> previousSchemas,
boolean normalize) |
List<String> |
SchemaRegistry.isCompatible(String subject,
Schema newSchema,
List<SchemaKey> previousSchemas,
boolean normalize) |
void |
SchemaIdAndSubjects.removeIf(Predicate<SchemaKey> filter) |
| Constructor and Description |
|---|
LazyParsedSchemaHolder(KafkaSchemaRegistry schemaRegistry,
SchemaKey schemaKey) |
Copyright © 2026 Confluent, Inc.. All rights reserved.