public class DataplaneAuthReader<K,V> extends KafkaReader<K,V>
KafkaReader.PartitionState
cache, consumerListener, partitionStates, prepareReaderStartupState
Constructor and Description |
---|
DataplaneAuthReader(String topic,
int numPartitions,
org.apache.kafka.clients.consumer.Consumer<K,V> consumer,
io.confluent.security.store.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 |
---|---|
void |
close(Duration closeTimeout) |
protected List<CompletableFuture<Void>> |
partitionReadyFutures()
We are not expecting Status messages for auth topic partitions from sync pipeline.
|
protected void |
processConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record) |
existingRecordsFuture, run, start
public DataplaneAuthReader(String topic, int numPartitions, org.apache.kafka.clients.consumer.Consumer<K,V> consumer, io.confluent.security.store.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>
protected void processConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
processConsumerRecord
in class KafkaReader<K,V>
public void close(Duration closeTimeout)
close
in class KafkaReader<K,V>