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, KafkaCDIEvents kafkaCDIEvents)

Method Summary

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

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,
                 KafkaCDIEvents kafkaCDIEvents)

Method Detail

getSink

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

isAlive

public void isAlive(HealthReport.HealthReportBuilder builder)

isReady

public void isReady(HealthReport.HealthReportBuilder builder)

closeQuietly

public void closeQuietly()