net.bluemind.central.reverse.proxy.model

Interface RecordHandler<T,U>

All Superinterfaces:

io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<T,U>>

All Known Implementing Classes:

ByteArrayRecordHandler

public interface RecordHandler<T,U>
extends io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<T,U>>

Method Summary

Modifier and Type	Method and Description
static RecordHandler<byte[],byte[]>	createByteHandler(ProxyInfoStoreClient client, io.vertx.core.Vertx vertx)
void	handle(org.apache.kafka.clients.consumer.ConsumerRecord<T,U> rec)

Method Detail

handle

void handle(org.apache.kafka.clients.consumer.ConsumerRecord<T,U> rec)

Specified by:

handle in interface io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<T,U>>

createByteHandler

static RecordHandler<byte[],byte[]> createByteHandler(ProxyInfoStoreClient client,
                                                      io.vertx.core.Vertx vertx)