io.confluent.kafka.schemaregistry.storage

Interface StoreUpdateHandler<K,V>

All Superinterfaces:

AutoCloseable, Closeable, org.apache.kafka.common.Configurable

All Known Subinterfaces:

SchemaUpdateHandler

All Known Implementing Classes:

CompositeSchemaUpdateHandler, KafkaStoreMessageHandler

public interface StoreUpdateHandler<K,V>
extends org.apache.kafka.common.Configurable, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	StoreUpdateHandler.ValidationStatus

Field Summary

Fields

Modifier and Type	Field and Description
static String	SCHEMA_REGISTRY

Method Summary

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

Field Detail

SCHEMA_REGISTRY

static final String SCHEMA_REGISTRY

See Also:

Constant Field Values

Method Detail

configure

default void configure(Map<String,?> map)

Specified by:

configure in interface org.apache.kafka.common.Configurable

cacheInitialized

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

Invoked after the cache is initialized.

startBatch

default void startBatch(int count)

Invoked before a batch of updates.

Parameters:

count - batch count

validateUpdate

default StoreUpdateHandler.ValidationStatus validateUpdate(K key,
                                                           V value,
                                                           org.apache.kafka.common.TopicPartition tp,
                                                           long offset,
                                                           long timestamp)

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

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

void handleUpdate(K key,
                  V value,
                  V oldValue,
                  org.apache.kafka.common.TopicPartition tp,
                  long offset,
                  long timestamp)

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

Parameters:

key - Key associated with the data

value - Data written to the store

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

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

Retrieve the offsets to checkpoint.

Parameters:

count - batch count

Returns:

the offsets to checkpoint, or null

endBatch

default void endBatch(int count)

Invoked after a batch of updates.

Parameters:

count - batch count

close

default void close()
            throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException