KafkaConsumerClientImpl (net.bluemind.parent 4.1.65246 API)

java.lang.Object
- net.bluemind.central.reverse.proxy.model.common.kafka.impl.KafkaConsumerClientImpl<K,V>

public class KafkaConsumerClientImpl<K,V>
extends java.lang.Object
implements KafkaConsumerClient<K,V>

Constructors
Constructor and Description
`KafkaConsumerClientImpl(io.vertx.core.Vertx vertx, java.util.Properties props)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`KafkaConsumerClientImpl<K,V>`	`batchHandler(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>> batchHandler)`
`KafkaConsumerClientImpl<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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface net.bluemind.central.reverse.proxy.model.common.kafka.KafkaConsumerClient
create

public KafkaConsumerClientImpl(io.vertx.core.Vertx vertx,
                               java.util.Properties props)

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

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

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

Class KafkaConsumerClientImpl<K,V>