io.micronaut.configuration.kafka.health

Class KafkaHealthIndicator

java.lang.Object

io.micronaut.configuration.kafka.health.KafkaHealthIndicator

All Implemented Interfaces:

Ordered, HealthIndicator

@Singleton
 @Requires(beans=org.apache.kafka.clients.admin.AdminClient.class)
public class KafkaHealthIndicator
extends Object
implements HealthIndicator

A HealthIndicator for Kafka.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields inherited from interface io.micronaut.core.order.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
KafkaHealthIndicator(AdminClient adminClient, KafkaDefaultConfiguration defaultConfiguration) Constructs a new Kafka health indicator for the given arguments.

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable<HealthResult>	getResult()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.core.order.Ordered

getOrder

Constructor Detail

KafkaHealthIndicator

public KafkaHealthIndicator(AdminClient adminClient,
                            KafkaDefaultConfiguration defaultConfiguration)

Constructs a new Kafka health indicator for the given arguments.

Parameters:

adminClient - The admin client

defaultConfiguration - The default configuration

Method Detail

getResult

public io.reactivex.Flowable<HealthResult> getResult()

Specified by:

getResult in interface HealthIndicator

Returns:

A publisher that returns a HealthResult that provides the information necessary to build a response.