Interface | Description |
---|---|
ConsumerListener<K,V> | |
StatusListener |
Interface to listener for failure status of KafkaStore readers and writers
|
Writer |
Class | Description |
---|---|
CachedRecord<K,V> | |
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 |