io.confluent.kafka.schemaregistry.storage.encoder

Class MetadataEncoderService

java.lang.Object

io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

All Implemented Interfaces:

Closeable, AutoCloseable

public class MetadataEncoderService
extends Object
implements Closeable

Constructor Summary

Constructors

Modifier	Constructor and Description
	MetadataEncoderService(SchemaRegistry schemaRegistry)
protected	MetadataEncoderService(SchemaRegistry schemaRegistry, io.kcache.Cache<String,KeysetWrapper> encoders)

Method Summary

Modifier and Type	Method and Description
void	close()
protected <K,V> io.kcache.Cache<K,V>	createCache(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde, String topic, io.kcache.CacheUpdateHandler<K,V> cacheUpdateHandler)
void	decodeMetadata(SchemaValue schema)
void	encodeMetadata(SchemaValue schema)
protected static String	encoderOldSecret(SchemaRegistryConfig config)
protected static String	encoderSecret(SchemaRegistryConfig config)
com.google.crypto.tink.KeysetHandle	getEncoder(String tenant)
io.kcache.Cache<String,KeysetWrapper>	getEncoders()
protected static com.google.crypto.tink.Aead	getPrimitive(String secret)
KafkaSchemaRegistry	getSchemaRegistry()
void	init()
void	waitForInit()

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataEncoderService

public MetadataEncoderService(SchemaRegistry schemaRegistry)

MetadataEncoderService

protected MetadataEncoderService(SchemaRegistry schemaRegistry,
                                 io.kcache.Cache<String,KeysetWrapper> encoders)

Method Detail

getSchemaRegistry

public KafkaSchemaRegistry getSchemaRegistry()

getEncoders

public io.kcache.Cache<String,KeysetWrapper> getEncoders()

getPrimitive

protected static com.google.crypto.tink.Aead getPrimitive(String secret)
                                                   throws GeneralSecurityException

Throws:

GeneralSecurityException

encoderSecret

protected static String encoderSecret(SchemaRegistryConfig config)

encoderOldSecret

protected static String encoderOldSecret(SchemaRegistryConfig config)

createCache

protected <K,V> io.kcache.Cache<K,V> createCache(org.apache.kafka.common.serialization.Serde<K> keySerde,
                                                 org.apache.kafka.common.serialization.Serde<V> valueSerde,
                                                 String topic,
                                                 io.kcache.CacheUpdateHandler<K,V> cacheUpdateHandler)
                                          throws io.kcache.exceptions.CacheInitializationException

Throws:

io.kcache.exceptions.CacheInitializationException

init

public void init()

waitForInit

public void waitForInit()
                 throws InterruptedException

Throws:

InterruptedException

getEncoder

public com.google.crypto.tink.KeysetHandle getEncoder(String tenant)

encodeMetadata

public void encodeMetadata(SchemaValue schema)
                    throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

decodeMetadata

public void decodeMetadata(SchemaValue schema)
                    throws SchemaRegistryStoreException

Throws:

SchemaRegistryStoreException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable