Package io.eventuate.messaging.kafka.basic.consumer

Interface EventuateKafkaConsumerMessageHandler

All Superinterfaces:
BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>,BiConsumer<Void,Throwable>,MessageConsumerBacklog>
public interface EventuateKafkaConsumerMessageHandler extends BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>,BiConsumer<Void,Throwable>,MessageConsumerBacklog>