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>

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)
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, com.yammer.metrics.core.Meter recordFailureMeter)

Method Summary

Modifier and Type	Method and Description
void	close(Duration closeTimeout)

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

existingRecordsFuture, run, start

Methods inherited from class java.lang.Object

equals, 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,
                           com.yammer.metrics.core.Meter recordFailureMeter)

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

close

public void close(Duration closeTimeout)

Overrides:

close in class KafkaReader<K,V>