net.bluemind.central.reverse.proxy.model.common.kafka

Interface KafkaConsumerClient<K,V>

All Known Implementing Classes:

KafkaConsumerClientImpl

public interface KafkaConsumerClient<K,V>

Method Summary

Modifier and Type	Method and Description
KafkaConsumerClient<K,V>	batchHandler(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>> batchHandler)
static <K,V> KafkaConsumerClient<K,V>	create(io.vertx.core.Vertx vertx, java.util.Properties props)
KafkaConsumerClient<K,V>	handler(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> handler)
io.vertx.core.Future<java.lang.Void>	subscribe(java.util.List<java.lang.String> topics)

Method Detail

create

static <K,V> KafkaConsumerClient<K,V> create(io.vertx.core.Vertx vertx,
                                             java.util.Properties props)

handler

KafkaConsumerClient<K,V> handler(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> handler)

batchHandler

KafkaConsumerClient<K,V> batchHandler(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>> batchHandler)

subscribe

io.vertx.core.Future<java.lang.Void> subscribe(java.util.List<java.lang.String> topics)