io.micronaut.configuration.kafka.reactor

Class KafkaReactorUtil

java.lang.Object

io.micronaut.configuration.kafka.reactor.KafkaReactorUtil

@Internal
public class KafkaReactorUtil
extends java.lang.Object

Utility methods for working with Kafka and Reactor.

Since:

4.0.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
KafkaReactorUtil()

Method Summary

Modifier and Type	Method and Description
static <T> reactor.core.publisher.Mono<T>	fromKafkaFuture(java.util.function.Supplier<KafkaFuture<T>> supplier) Factory for creating Mono instances from Kafka Future instances.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaReactorUtil

public KafkaReactorUtil()

Method Detail

fromKafkaFuture

public static <T> reactor.core.publisher.Mono<T> fromKafkaFuture(java.util.function.Supplier<KafkaFuture<T>> supplier)

Factory for creating Mono instances from Kafka Future instances.

Type Parameters:

T - The type

Parameters:

supplier - The supplier

Returns:

The Mono