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

接口 DefaultReactorKafkaHandler

所有超级接口:

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

public interface DefaultReactorKafkaHandler
extends ReactorKafkaHandler<String,String>

Default Reactor Kafka Handler.

方法概要

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

andThen, apply, compose