public class KafkaReader<K,V>
extends java.lang.Object
implements java.lang.Runnable
Constructor and Description |
---|
KafkaReader(java.lang.String topic,
int numPartitions,
org.apache.kafka.clients.consumer.Consumer<K,V> consumer,
KeyValueStore<K,V> cache,
ConsumerListener<K,V> consumerListener,
StatusListener statusListener,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
close(java.time.Duration closeTimeout) |
void |
run() |
java.util.concurrent.CompletionStage<java.lang.Void> |
start(java.time.Duration topicCreateTimeout) |
public KafkaReader(java.lang.String topic, int numPartitions, org.apache.kafka.clients.consumer.Consumer<K,V> consumer, KeyValueStore<K,V> cache, ConsumerListener<K,V> consumerListener, StatusListener statusListener, org.apache.kafka.common.utils.Time time)