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 |