io.smallrye.reactive.messaging.kafka.health

Class KafkaSourceHealth

java.lang.Object

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

io.smallrye.reactive.messaging.kafka.health.KafkaSourceHealth

public class KafkaSourceHealth
extends BaseHealth

Field Summary

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

CONNECTION_COUNT_METRIC_NAME

Constructor Summary

Constructors

Constructor and Description
KafkaSourceHealth(KafkaSource<?,?> source, KafkaConnectorIncomingConfiguration config, ReactiveKafkaConsumer<?,?> client)

Method Summary

Modifier and Type	Method and 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

KafkaSourceHealth

public KafkaSourceHealth(KafkaSource<?,?> source,
                         KafkaConnectorIncomingConfiguration config,
                         ReactiveKafkaConsumer<?,?> client)

Method Detail

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

getAdmin

public KafkaAdmin getAdmin()

Specified by:

getAdmin in class BaseHealth