Package io.confluent.kafka.schemaregistry.storage

Class KafkaStoreMessageHandler

java.lang.Object

io.confluent.kafka.schemaregistry.storage.KafkaStoreMessageHandler

All Implemented Interfaces:

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

public class KafkaStoreMessageHandler
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
KafkaStoreMessageHandler(SchemaRegistry schemaRegistry, LookupCache<SchemaRegistryKey,SchemaRegistryValue> lookupCache, IdGenerator idGenerator)

Method Summary

Modifier and Type	Method	Description
protected static void	canonicalize(SchemaProvider schemaProvider, SchemaValue schemaValue)
Map<org.apache.kafka.common.TopicPartition,Long>	checkpoint(int count)	Retrieve the offsets to checkpoint.
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
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

cacheInitialized, close, configure, endBatch, init, startBatch

Constructor Details

KafkaStoreMessageHandler

public KafkaStoreMessageHandler(SchemaRegistry schemaRegistry,
 LookupCache<SchemaRegistryKey,SchemaRegistryValue> lookupCache,
 IdGenerator idGenerator)

Method Details

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

canonicalize

protected static void canonicalize(SchemaProvider schemaProvider,
 SchemaValue schemaValue)

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