Package io.confluent.security.store.kafka.clients
package io.confluent.security.store.kafka.clients
-
ClassDescriptionCachedRecord<K,
V> ConsumerListener<K,V> ErrorHandlingJsonSerde that catches exceptions while deserializing key/value of the records and returns the value as per the user provided handleDeserializationExceptionFunctionJsonSerde<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> Interface to listener for failure status of KafkaStore readers and writers