Package 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	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	Description
void	close(Duration closeTimeout)
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

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

Constructor Details

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 Details

processConsumerRecord

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

close

public void close(Duration closeTimeout)

Overrides:

close in class KafkaReader<K,V>