Package io.smallrye.reactive.messaging.kafka.impl

Class KafkaSink

java.lang.Object

io.smallrye.reactive.messaging.kafka.impl.KafkaSink

public class KafkaSink
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaSink(io.vertx.mutiny.core.Vertx vertx, KafkaConnectorOutgoingConfiguration config)

Method Summary

Modifier and Type	Method	Description
void	closeQuietly()
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	getSink()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSink

public KafkaSink(io.vertx.mutiny.core.Vertx vertx,
                 KafkaConnectorOutgoingConfiguration config)

Method Detail

getSink

public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> getSink()

closeQuietly

public void closeQuietly()