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

Class BackupSchemaFetcher

java.lang.Object

io.confluent.connect.schema.backup.core.BackupSchemaFetcher

public class BackupSchemaFetcher
extends Object

Fetches schema metadata and builds reference trees from Schema Registry for backup.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BackupSchemaFetcher.BackupSchemaInfo
static class	BackupSchemaFetcher.RefTreeEntry

Constructor Summary

Constructors

Constructor	Description
BackupSchemaFetcher(SchemaRegistryClient schemaRegistry)

Method Summary

Modifier and Type	Method	Description
BackupSchemaFetcher.BackupSchemaInfo	fetchSchemaInfo(int schemaId)
BackupSchemaFetcher.BackupSchemaInfo	fetchSchemaInfoByGuid(String guid)

Methods inherited from class java.lang.Object

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

Constructor Details

BackupSchemaFetcher

public BackupSchemaFetcher(SchemaRegistryClient schemaRegistry)

Method Details

fetchSchemaInfo

public BackupSchemaFetcher.BackupSchemaInfo fetchSchemaInfo(int schemaId)
                                                     throws IOException,
RestClientException

Throws:

IOException

RestClientException

fetchSchemaInfoByGuid

public BackupSchemaFetcher.BackupSchemaInfo fetchSchemaInfoByGuid(String guid)
                                                           throws IOException,
RestClientException

Throws:

IOException

RestClientException