Package io.confluent.connect.schema.backup.core

Class BackupReferenceResolver

java.lang.Object

io.confluent.connect.schema.backup.core.BackupReferenceResolver

public class BackupReferenceResolver
extends Object

Resolves and registers schema references in the target Schema Registry during restore.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BackupReferenceResolver.ParsedSchemaFactory
static class	BackupReferenceResolver.ResolutionResult

Constructor Summary

Constructors

Constructor	Description
BackupReferenceResolver(SchemaRegistryClient schemaRegistry)

Method Summary

Modifier and Type	Method	Description
static List<SchemaReference>	parseDirectRefs(String json)
static Map<String,BackupSchemaFetcher.RefTreeEntry>	parseReferenceTree(String json)
void	registerRefsRecursive(List<SchemaReference> refs, Map<String,BackupSchemaFetcher.RefTreeEntry> tree, BackupReferenceResolver.ParsedSchemaFactory factory, List<SchemaReference> targetRefsOut, Map<String,String> resolvedSchemasOut)
BackupReferenceResolver.ResolutionResult	resolveFromWrapper(org.apache.kafka.connect.data.Schema wrapperSchema, org.apache.kafka.connect.data.Struct wrapper, BackupReferenceResolver.ParsedSchemaFactory factory)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BackupReferenceResolver

public BackupReferenceResolver(SchemaRegistryClient schemaRegistry)

Method Details

resolveFromWrapper

public BackupReferenceResolver.ResolutionResult resolveFromWrapper(org.apache.kafka.connect.data.Schema wrapperSchema,
 org.apache.kafka.connect.data.Struct wrapper,
 BackupReferenceResolver.ParsedSchemaFactory factory)

parseReferenceTree

public static Map<String,BackupSchemaFetcher.RefTreeEntry> parseReferenceTree(String json)

parseDirectRefs

public static List<SchemaReference> parseDirectRefs(String json)

registerRefsRecursive

public void registerRefsRecursive(List<SchemaReference> refs,
 Map<String,BackupSchemaFetcher.RefTreeEntry> tree,
 BackupReferenceResolver.ParsedSchemaFactory factory,
 List<SchemaReference> targetRefsOut,
 Map<String,String> resolvedSchemasOut)