程序包 io.github.wooenrico.kafka.handler

接口 ReactorKafkaHandler<K,V>

类型参数:

K -

V -

所有超级接口:

Function<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,reactor.core.publisher.Mono<Void>>, IKafkaHandler

所有已知子接口:

DefaultReactorKafkaHandler

public interface ReactorKafkaHandler<K,V>
extends IKafkaHandler, Function<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,reactor.core.publisher.Mono<Void>>

Reactor Kafka Handler.

方法概要

从接口继承的方法 java.util.function.Function

andThen, apply, compose