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