public class DataplaneAuthReader<K,V> extends KafkaReader<K,V>
KafkaReader.PartitionState
partitionStates
Constructor and Description |
---|
DataplaneAuthReader(String topic,
int numPartitions,
org.apache.kafka.clients.consumer.Consumer<K,V> consumer,
KeyValueStore<K,V> cache,
ConsumerListener<K,V> consumerListener,
StatusListener statusListener,
KafkaStoreConfig kafkaStoreConfig,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
protected List<CompletableFuture<Void>> |
partitionReadyFutures()
We are not expecting Status messages for auth topic partitions from sync pipeline.
|
close, existingRecordsFuture, run, start
public DataplaneAuthReader(String topic, int numPartitions, org.apache.kafka.clients.consumer.Consumer<K,V> consumer, KeyValueStore<K,V> cache, ConsumerListener<K,V> consumerListener, StatusListener statusListener, KafkaStoreConfig kafkaStoreConfig, org.apache.kafka.common.utils.Time time)
protected List<CompletableFuture<Void>> partitionReadyFutures()
partitionReadyFutures
in class KafkaReader<K,V>