Package io.confluent.kafka.schemaregistry.storage

Class KafkaStore<K,V>

java.lang.Object

io.confluent.kafka.schemaregistry.storage.KafkaStore<K,V>

All Implemented Interfaces:

Store<K,V>, AutoCloseable

public class KafkaStore<K,V>
extends Object
implements Store<K,V>

Constructor Summary

Constructors

Constructor	Description
KafkaStore(SchemaRegistryConfig config, StoreUpdateHandler<K,V> storeUpdateHandler, Serializer<K,V> serializer, Store<K,V> localStore, K noopKey)

Method Summary

Modifier and Type	Method	Description
static void	addSchemaRegistryConfigsToClientProperties(SchemaRegistryConfig config, Properties props)
void	close()
V	delete(K key)
void	flush()
V	get(K key)
CloseableIterator<V>	getAll(K key1, K key2)	Iterator over keys in the specified range
CloseableIterator<K>	getAllKeys()
void	init()
boolean	initialized()
long	lastOffset(String subject)
Lock	leaderLock()
Lock	lockFor(String subject)
void	markLastWrittenOffsetInvalid()
V	put(K key, V value)
void	putAll(Map<K,V> entries)
void	setLastOffset(String subject, long lastOffset)
void	waitForInit()
void	waitUntilKafkaReaderReachesLastOffset(int timeoutMs)	Wait until the KafkaStore catches up to the last message in the Kafka topic.
void	waitUntilKafkaReaderReachesLastOffset(String subject, int timeoutMs)	Wait until the KafkaStore catches up to the last message for the given subject.

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.Store

isPersistent

Constructor Details

KafkaStore

public KafkaStore(SchemaRegistryConfig config,
 StoreUpdateHandler<K,V> storeUpdateHandler,
 Serializer<K,V> serializer,
 Store<K,V> localStore,
 K noopKey)
           throws SchemaRegistryException

Throws:

SchemaRegistryException

Method Details

init

public void init()
          throws StoreInitializationException

Specified by:

init in interface Store<K,V>

Throws:

StoreInitializationException

addSchemaRegistryConfigsToClientProperties

public static void addSchemaRegistryConfigsToClientProperties(SchemaRegistryConfig config,
 Properties props)

waitUntilKafkaReaderReachesLastOffset

public void waitUntilKafkaReaderReachesLastOffset(int timeoutMs)
                                           throws StoreException

Wait until the KafkaStore catches up to the last message in the Kafka topic.

Throws:

StoreException

waitUntilKafkaReaderReachesLastOffset

public void waitUntilKafkaReaderReachesLastOffset(String subject,
 int timeoutMs)
                                           throws StoreException

Wait until the KafkaStore catches up to the last message for the given subject.

Throws:

StoreException

markLastWrittenOffsetInvalid

public void markLastWrittenOffsetInvalid()

get

public V get(K key)
      throws StoreException

Specified by:

get in interface Store<K,V>

Throws:

StoreException

put

public V put(K key,
 V value)
      throws StoreTimeoutException,
StoreException

Specified by:

put in interface Store<K,V>

Throws:

StoreTimeoutException

StoreException

getAll

public CloseableIterator<V> getAll(K key1,
 K key2)
                            throws StoreException

Description copied from interface: Store

Iterator over keys in the specified range

Specified by:

getAll in interface Store<K,V>

Parameters:

key1 - If key1 is null, start from the first key in sorted order

key2 - If key2 is null, end at the last key

Returns:

Iterator over keys in the half-open interval [key1, key2). If both keys are null, return an iterator over all keys in the database

Throws:

StoreException

putAll

public void putAll(Map<K,V> entries)
            throws StoreException

Specified by:

putAll in interface Store<K,V>

Throws:

StoreException

delete

public V delete(K key)
         throws StoreException

Specified by:

delete in interface Store<K,V>

Throws:

StoreException

getAllKeys

public CloseableIterator<K> getAllKeys()
                                throws StoreException

Specified by:

getAllKeys in interface Store<K,V>

Throws:

StoreException

flush

public void flush()
           throws StoreException

Specified by:

flush in interface Store<K,V>

Throws:

StoreException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Store<K,V>

waitForInit

public void waitForInit()
                 throws InterruptedException

Throws:

InterruptedException

initialized

public boolean initialized()

lastOffset

public long lastOffset(String subject)

setLastOffset

public void setLastOffset(String subject,
 long lastOffset)

leaderLock

public Lock leaderLock()

lockFor

public Lock lockFor(String subject)