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(KafkaConnectorOutgoingConfiguration config, KafkaCDIEvents kafkaCDIEvents, javax.enterprise.inject.Instance<SerializationFailureHandler<?>> serializationFailureHandlers)

Method Summary

Modifier and Type	Method	Description
void	closeQuietly()
String	getChannel()
KafkaProducer<?,?>	getProducer()
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	getSink()
void	isAlive(HealthReport.HealthReportBuilder builder)
void	isReady(HealthReport.HealthReportBuilder builder)
void	isStarted(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(KafkaConnectorOutgoingConfiguration config,
                 KafkaCDIEvents kafkaCDIEvents,
                 javax.enterprise.inject.Instance<SerializationFailureHandler<?>> serializationFailureHandlers)

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)

isStarted

public void isStarted(HealthReport.HealthReportBuilder builder)

closeQuietly

public void closeQuietly()

getChannel

public String getChannel()

getProducer

public KafkaProducer<?,?> getProducer()