Package | Description |
---|---|
net.bluemind.central.reverse.proxy.model.common.kafka | |
net.bluemind.central.reverse.proxy.model.common.kafka.impl |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaConsumerClientImpl<K,V> |
Copyright © 2023. All Rights Reserved.