io.confluent.kafka.schemaregistry.storage

Class KafkaStoreReaderThread<K,V>

java.lang.Object

java.lang.Thread

io.confluent.kafka.schemaregistry.utils.ShutdownableThread

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

All Implemented Interfaces:

Runnable

public class KafkaStoreReaderThread<K,V>
extends ShutdownableThread

Thread that reads schema registry state from the Kafka compacted topic and modifies the local store to be consistent.

On startup, this thread will always read from the beginning of the topic. We assume the topic will always be small, hence the startup time to read the topic won't take too long. Because the topic is always read from the beginning, the consumer never commits offsets.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class io.confluent.kafka.schemaregistry.utils.ShutdownableThread

logPrefix

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
KafkaStoreReaderThread(String bootstrapBrokers, String topic, String groupId, StoreUpdateHandler<K,V> storeUpdateHandler, Serializer<K,V> serializer, Store<K,V> localStore, org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer, K noopKey, AtomicBoolean initialized, SchemaRegistryConfig config)

Method Summary

Modifier and Type	Method and Description
Map<org.apache.kafka.common.TopicPartition,Long>	checkpoints()
void	doWork() This method is repeatedly invoked until the thread shuts down or this method throws an exception
String	getConsumerProperty(String key)
void	shutdown()
void	waitUntilOffset(long offset, long timeout, TimeUnit timeUnit)

Methods inherited from class io.confluent.kafka.schemaregistry.utils.ShutdownableThread

awaitShutdown, initiateShutdown, isRunning, isShutdownComplete, isShutdownInitiated, isThreadFailed, pause, run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaStoreReaderThread

public KafkaStoreReaderThread(String bootstrapBrokers,
                              String topic,
                              String groupId,
                              StoreUpdateHandler<K,V> storeUpdateHandler,
                              Serializer<K,V> serializer,
                              Store<K,V> localStore,
                              org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer,
                              K noopKey,
                              AtomicBoolean initialized,
                              SchemaRegistryConfig config)

Method Detail

checkpoints

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

doWork

public void doWork()

Description copied from class: ShutdownableThread

This method is repeatedly invoked until the thread shuts down or this method throws an exception

Specified by:

doWork in class ShutdownableThread

shutdown

public void shutdown()

Overrides:

shutdown in class ShutdownableThread

waitUntilOffset

public void waitUntilOffset(long offset,
                            long timeout,
                            TimeUnit timeUnit)
                     throws StoreException

Throws:

StoreException

getConsumerProperty

public String getConsumerProperty(String key)