Package io.confluent.security.store.kafka.clients

Class KafkaReader<K,V>

java.lang.Object

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

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

DataplaneAuthReader

public class KafkaReader<K,V>
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor	Description
KafkaReader(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 storeConfig, org.apache.kafka.common.utils.Time time)

Method Summary

Modifier and Type	Method	Description
void	close(Duration closeTimeout)
CompletableFuture<Void>	existingRecordsFuture()	Returns future that completes when existing records on all partitions at the time the KafkaReader was started are processed and available in the cache.
void	run()
CompletionStage<Void>	start(Duration topicCreateTimeout)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaReader

public KafkaReader(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 storeConfig,
 org.apache.kafka.common.utils.Time time)

Method Details

start

public CompletionStage<Void> start(Duration topicCreateTimeout)

run

public void run()

Specified by:

run in interface Runnable

existingRecordsFuture

public CompletableFuture<Void> existingRecordsFuture()

Returns future that completes when existing records on all partitions at the time the KafkaReader was started are processed and available in the cache.

close

public void close(Duration closeTimeout)