void |
KafkaSchemaRegistry.deleteConfigOrForward(String subject,
Map<String,String> headerProperties) |
void |
KafkaSchemaRegistry.deleteSubjectConfig(String subject) |
void |
KafkaSchemaRegistry.deleteSubjectMode(String subject) |
void |
KafkaSchemaRegistry.deleteSubjectModeOrForward(String subject,
Map<String,String> headerProperties) |
Config |
KafkaSchemaRegistry.getConfig(String subject) |
Config |
KafkaSchemaRegistry.getConfigInScope(String subject) |
HostnameVerifier |
KafkaSchemaRegistry.getHostnameVerifier() |
Mode |
KafkaSchemaRegistry.getMode(String subject) |
Mode |
KafkaSchemaRegistry.getModeInScope(String subject) |
boolean |
KafkaSchemaRegistry.hasSubjects(String subject,
boolean lookupDeletedSubjects) |
void |
LeaderElector.init() |
void |
KafkaSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader)
'Inform' this SchemaRegistry instance which SchemaRegistry is the current leader.
|
void |
LeaderAwareSchemaRegistry.setLeader(SchemaRegistryIdentity newLeader) |
Set<String> |
KafkaSchemaRegistry.subjects(String subject,
boolean lookupDeletedSubjects) |
Schema |
KafkaSchemaRegistry.toSchemaEntity(SchemaValue schemaValue) |
Config |
KafkaSchemaRegistry.updateConfig(String subject,
ConfigUpdateRequest config) |
Config |
KafkaSchemaRegistry.updateConfigOrForward(String subject,
ConfigUpdateRequest newConfig,
Map<String,String> headerProperties) |