Package io.confluent.kafka.schemaregistry.storage

Class CompositeSchemaUpdateHandler

java.lang.Object

io.confluent.kafka.schemaregistry.storage.CompositeSchemaUpdateHandler

All Implemented Interfaces:

SchemaUpdateHandler, StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>, Closeable, AutoCloseable, org.apache.kafka.common.Configurable

public class CompositeSchemaUpdateHandler
extends Object
implements SchemaUpdateHandler

Nested Class Summary

Nested classes/interfaces inherited from interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler

StoreUpdateHandler.ValidationStatus

Field Summary

Fields inherited from interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler

SCHEMA_REGISTRY

Constructor Summary

Constructors

Constructor	Description
CompositeSchemaUpdateHandler(List<SchemaUpdateHandler> handlers)

Method Summary

Modifier and Type	Method	Description
void	cacheInitialized(Map<org.apache.kafka.common.TopicPartition,Long> checkpoints)	Invoked after the cache is initialized.
Map<org.apache.kafka.common.TopicPartition,Long>	checkpoint(int count)	Retrieve the offsets to checkpoint.
void	close()
void	endBatch(int count)	Invoked after a batch of updates.
void	handleUpdate(SchemaRegistryKey key, SchemaRegistryValue value, SchemaRegistryValue oldValue, org.apache.kafka.common.TopicPartition tp, long offset, long timestamp)	Invoked on every new schema written to the Kafka store
void	init(Map<org.apache.kafka.common.TopicPartition,Long> checkpoints)	Invoked before the cache is initialized.
void	startBatch(int count)	Invoked before a batch of updates.
StoreUpdateHandler.ValidationStatus	validateUpdate(SchemaRegistryKey key, SchemaRegistryValue value, org.apache.kafka.common.TopicPartition tp, long offset, long timestamp)	Invoked before every new K,V pair written to the store

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.kafka.schemaregistry.storage.StoreUpdateHandler

configure

Constructor Details

CompositeSchemaUpdateHandler

public CompositeSchemaUpdateHandler(List<SchemaUpdateHandler> handlers)

Method Details

init

public void init(Map<org.apache.kafka.common.TopicPartition,Long> checkpoints)
          throws StoreInitializationException

Invoked before the cache is initialized.

Specified by:

init in interface StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>

Throws:

StoreInitializationException

cacheInitialized

public void cacheInitialized(Map<org.apache.kafka.common.TopicPartition,Long> checkpoints)

Invoked after the cache is initialized.

Specified by:

cacheInitialized in interface StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>

startBatch

public void startBatch(int count)

Description copied from interface: StoreUpdateHandler

Invoked before a batch of updates.

Specified by:

startBatch in interface StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

count - batch count

validateUpdate

public StoreUpdateHandler.ValidationStatus validateUpdate(SchemaRegistryKey key,
 SchemaRegistryValue value,
 org.apache.kafka.common.TopicPartition tp,
 long offset,
 long timestamp)

Invoked before every new K,V pair written to the store

Specified by:

validateUpdate in interface StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

key - Key associated with the data

value - Data written to the store

tp - Topic-partition

offset - Offset of record

timestamp - Timestamp of record

handleUpdate

public void handleUpdate(SchemaRegistryKey key,
 SchemaRegistryValue value,
 SchemaRegistryValue oldValue,
 org.apache.kafka.common.TopicPartition tp,
 long offset,
 long timestamp)

Invoked on every new schema written to the Kafka store

Specified by:

handleUpdate in interface StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

key - Key associated with the schema.

value - Value written to the Kafka lookupCache

oldValue - the previous value associated with key, or null if there was no mapping for key

tp - Topic-partition

offset - Offset of record

timestamp - Timestamp of record

checkpoint

public Map<org.apache.kafka.common.TopicPartition,Long> checkpoint(int count)

Description copied from interface: StoreUpdateHandler

Retrieve the offsets to checkpoint.

Specified by:

checkpoint in interface StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

count - batch count

Returns:

the offsets to checkpoint, or null

endBatch

public void endBatch(int count)

Description copied from interface: StoreUpdateHandler

Invoked after a batch of updates.

Specified by:

endBatch in interface StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>

Parameters:

count - batch count

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface StoreUpdateHandler<SchemaRegistryKey,SchemaRegistryValue>

Throws:

IOException