Package io.smallrye.reactive.messaging.kafka.health

Class KafkaSinkHealth

java.lang.Object

io.smallrye.reactive.messaging.kafka.health.BaseHealth

io.smallrye.reactive.messaging.kafka.health.KafkaSinkHealth

public class KafkaSinkHealth
extends BaseHealth

Field Summary

Fields inherited from class io.smallrye.reactive.messaging.kafka.health.BaseHealth

channel, CONNECTION_COUNT_METRIC_NAME

Constructor Summary

Constructors

Constructor	Description
KafkaSinkHealth(KafkaConnectorOutgoingConfiguration config, Map<String,?> kafkaConfiguration, org.apache.kafka.clients.producer.Producer<?,?> producer)

Method Summary

Modifier and Type	Method	Description
protected void	clientBasedReadinessCheck(HealthReport.HealthReportBuilder builder)
protected void	clientBasedStartupCheck(HealthReport.HealthReportBuilder builder)
KafkaAdmin	getAdmin()
protected void	metricsBasedReadinessCheck(HealthReport.HealthReportBuilder builder)
protected void	metricsBasedStartupCheck(HealthReport.HealthReportBuilder builder)

Methods inherited from class io.smallrye.reactive.messaging.kafka.health.BaseHealth

close, getMetric, isReady, isStarted

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSinkHealth

public KafkaSinkHealth(KafkaConnectorOutgoingConfiguration config,
                       Map<String,?> kafkaConfiguration,
                       org.apache.kafka.clients.producer.Producer<?,?> producer)

Method Detail

getAdmin

public KafkaAdmin getAdmin()

Specified by:

getAdmin in class BaseHealth

metricsBasedStartupCheck

protected void metricsBasedStartupCheck(HealthReport.HealthReportBuilder builder)

Specified by:

metricsBasedStartupCheck in class BaseHealth

metricsBasedReadinessCheck

protected void metricsBasedReadinessCheck(HealthReport.HealthReportBuilder builder)

Specified by:

metricsBasedReadinessCheck in class BaseHealth

clientBasedStartupCheck

protected void clientBasedStartupCheck(HealthReport.HealthReportBuilder builder)

Specified by:

clientBasedStartupCheck in class BaseHealth

clientBasedReadinessCheck

protected void clientBasedReadinessCheck(HealthReport.HealthReportBuilder builder)

Specified by:

clientBasedReadinessCheck in class BaseHealth