io.confluent.security.auth.dataplane

Class DataplaneAuthReader<K,V>

java.lang.Object

io.confluent.security.store.kafka.clients.KafkaReader<K,V>

io.confluent.security.auth.dataplane.DataplaneAuthReader<K,V>

All Implemented Interfaces:

Runnable

public class DataplaneAuthReader<K,V>
extends KafkaReader<K,V>

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.security.store.kafka.clients.KafkaReader

KafkaReader.PartitionState

Field Summary

Fields inherited from class io.confluent.security.store.kafka.clients.KafkaReader

cache, consumerListener, partitionStates, prepareReaderStartupState

Constructor Summary

Constructors

Constructor and Description
DataplaneAuthReader(String topic, int numPartitions, Future<org.apache.kafka.clients.consumer.Consumer<K,V>> consumerFuture, io.confluent.security.store.KeyValueStore<K,V> cache, ConsumerListener<K,V> consumerListener, StatusListener statusListener, KafkaStoreConfig kafkaStoreConfig, org.apache.kafka.common.utils.Time time)

Method Summary

Modifier and Type	Method and Description
void	close(Duration closeTimeout)
protected CompletableFuture<Void>	existingRecordsFuture(org.apache.kafka.common.TopicPartition topicPartition)
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)

Methods inherited from class io.confluent.security.store.kafka.clients.KafkaReader

existingRecordsFuture, run, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataplaneAuthReader

public DataplaneAuthReader(String topic,
                           int numPartitions,
                           Future<org.apache.kafka.clients.consumer.Consumer<K,V>> consumerFuture,
                           io.confluent.security.store.KeyValueStore<K,V> cache,
                           ConsumerListener<K,V> consumerListener,
                           StatusListener statusListener,
                           KafkaStoreConfig kafkaStoreConfig,
                           org.apache.kafka.common.utils.Time time)

Method Detail

partitionReadyFutures

protected List<CompletableFuture<Void>> partitionReadyFutures()

We are not expecting Status messages for auth topic partitions from sync pipeline. partitions are ready once we read all the existing records from the auth topic

Overrides:

partitionReadyFutures in class KafkaReader<K,V>

existingRecordsFuture

protected CompletableFuture<Void> existingRecordsFuture(org.apache.kafka.common.TopicPartition topicPartition)

processConsumerRecord

protected void processConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)

Overrides:

processConsumerRecord in class KafkaReader<K,V>

close

public void close(Duration closeTimeout)

Overrides:

close in class KafkaReader<K,V>