Package io.micronaut.configuration.kafka.reactor

Class KafkaReactorUtil

java.lang.Object

io.micronaut.configuration.kafka.reactor.KafkaReactorUtil

@Internal
public class KafkaReactorUtil
extends Object

Utility methods for working with Kafka and Reactor.

Since:

4.0.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor	Description
KafkaReactorUtil()

Method Summary

Modifier and Type	Method	Description
static <T> reactor.core.publisher.Mono<T>	fromKafkaFuture(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 Details

KafkaReactorUtil

public KafkaReactorUtil()

Method Details

fromKafkaFuture

public static <T> reactor.core.publisher.Mono<T> fromKafkaFuture(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