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

Class BackupConverterHelper

java.lang.Object

io.confluent.connect.schema.backup.core.BackupConverterHelper

public class BackupConverterHelper
extends Object

Shared helper for backup metadata wrapping in SR converters.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BackupConverterHelper.SubjectNameComputer

Constructor Summary

Constructors

Constructor	Description
BackupConverterHelper(SchemaRegistryClient schemaRegistry, Map<org.apache.kafka.connect.data.Schema,org.apache.kafka.connect.data.Schema> wrapperSchemaCache)

Method Summary

Modifier and Type	Method	Description
BackupReferenceResolver	getReferenceResolver()
static boolean	isBackupEnabled(Map<String,?> configs)
org.apache.kafka.connect.data.SchemaAndValue	wrapWithBackupMetadata(org.apache.kafka.connect.data.SchemaAndValue original, String topic, ParsedSchemaAndValue.SchemaInfo schemaInfo, String schemaType, boolean isKey, BackupReferenceResolver.ParsedSchemaFactory schemaFactory, BackupConverterHelper.SubjectNameComputer subjectComputer)

Methods inherited from class java.lang.Object

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

Constructor Details

BackupConverterHelper

public BackupConverterHelper(SchemaRegistryClient schemaRegistry,
 Map<org.apache.kafka.connect.data.Schema,org.apache.kafka.connect.data.Schema> wrapperSchemaCache)

Method Details

getReferenceResolver

public BackupReferenceResolver getReferenceResolver()

isBackupEnabled

public static boolean isBackupEnabled(Map<String,?> configs)

wrapWithBackupMetadata

public org.apache.kafka.connect.data.SchemaAndValue wrapWithBackupMetadata(org.apache.kafka.connect.data.SchemaAndValue original,
 String topic,
 ParsedSchemaAndValue.SchemaInfo schemaInfo,
 String schemaType,
 boolean isKey,
 BackupReferenceResolver.ParsedSchemaFactory schemaFactory,
 BackupConverterHelper.SubjectNameComputer subjectComputer)
                                                                    throws IOException,
RestClientException

Throws:

IOException

RestClientException