| Interface | Description |
|---|---|
| ConsumerListener<K,V> | |
| StatusListener |
Interface to listener for failure status of KafkaStore readers and writers
|
| Writer |
| Class | Description |
|---|---|
| CachedRecord<K,V> | |
| DeserializationErrorHandlingJsonSerde<T> |
ErrorHandlingJsonSerde that catches exceptions while deserializing key/value of the
records and returns the value as per the user provided handleDeserializationExceptionFunction
|
| DeserializationErrorHandlingJsonSerde.DeserializationError | |
| JsonSerde<T> | |
| KafkaPartitionWriter<K,V> |
Writer for one metadata topic partition that encapsulates all the state associated with
the partition including master writer generation.
|
| KafkaReader<K,V> | |
| KafkaUtils |