Package io.confluent.kafka.schemaregistry.storage.encoder

Class KafkaMetadataEncoderService

java.lang.Object

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

io.confluent.kafka.schemaregistry.storage.encoder.KafkaMetadataEncoderService

All Implemented Interfaces:

Closeable, AutoCloseable

public class KafkaMetadataEncoderService
extends MetadataEncoderService

Field Summary

Fields

Modifier and Type	Field	Description
protected io.kcache.Cache<String,KeysetWrapper>	encoders

Fields inherited from class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

encoderSecret, initialized, initLatch, keyTemplate

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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)
protected void	doInit()	Subclass hook to prepare any resources before secret rotation occurs.
protected Set<String>	getAllTenants()	Get all tenant keys.
com.google.crypto.tink.KeysetHandle	getEncoder(String tenant)
protected KeysetWrapper	getEncoderWrapper(String tenant)	Get the encoder wrapper for a tenant.
protected com.google.crypto.tink.KeysetHandle	getOrCreateEncoder(String tenant)
protected void	putEncoderWrapper(String tenant, KeysetWrapper wrapper)	Store an encoder wrapper for a tenant.

Methods inherited from class io.confluent.kafka.schemaregistry.storage.encoder.MetadataEncoderService

decodeMetadata, encodeMetadata, encoderOldSecret, encoderSecret, getPrimitive, getSchemaRegistry, init, maybeRotateSecrets, waitForInit

Methods inherited from class java.lang.Object

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

Field Details

encoders

protected io.kcache.Cache<String,KeysetWrapper> encoders

Constructor Details

KafkaMetadataEncoderService

public KafkaMetadataEncoderService(SchemaRegistry schemaRegistry)

KafkaMetadataEncoderService

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

Method Details

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

doInit

protected void doInit()

Description copied from class: MetadataEncoderService

Subclass hook to prepare any resources before secret rotation occurs. Default is no-op.

Overrides:

doInit in class MetadataEncoderService

getAllTenants

protected Set<String> getAllTenants()

Description copied from class: MetadataEncoderService

Get all tenant keys. Used for secret rotation.

Specified by:

getAllTenants in class MetadataEncoderService

getEncoderWrapper

protected KeysetWrapper getEncoderWrapper(String tenant)

Description copied from class: MetadataEncoderService

Get the encoder wrapper for a tenant.

Specified by:

getEncoderWrapper in class MetadataEncoderService

putEncoderWrapper

protected void putEncoderWrapper(String tenant,
 KeysetWrapper wrapper)

Description copied from class: MetadataEncoderService

Store an encoder wrapper for a tenant.

Specified by:

putEncoderWrapper in class MetadataEncoderService

getEncoder

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

Specified by:

getEncoder in class MetadataEncoderService

getOrCreateEncoder

protected com.google.crypto.tink.KeysetHandle getOrCreateEncoder(String tenant)

Specified by:

getOrCreateEncoder in class MetadataEncoderService

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class MetadataEncoderService