public class DataplaneAuthReader<K,V> extends KafkaReader<K,V>
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) |
Modifier and Type | Method and Description |
---|---|
void |
close(Duration closeTimeout) |
existingRecordsFuture, run, start
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)
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)
public void close(Duration closeTimeout)
close
in class KafkaReader<K,V>