org.springframework.cloud.stream.binder.kafka

Class KafkaBinderHealthIndicator

java.lang.Object

org.springframework.cloud.stream.binder.kafka.KafkaBinderHealthIndicator

All Implemented Interfaces:

org.springframework.boot.actuate.health.HealthIndicator

public class KafkaBinderHealthIndicator
extends Object
implements org.springframework.boot.actuate.health.HealthIndicator

Health indicator for Kafka.

Author:

Ilayaperumal Gopinathan, Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
KafkaBinderHealthIndicator(KafkaMessageChannelBinder binder, org.springframework.cloud.stream.binder.kafka.properties.KafkaBinderConfigurationProperties configurationProperties)

Method Summary

Modifier and Type	Method and Description
org.springframework.boot.actuate.health.Health	health()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaBinderHealthIndicator

public KafkaBinderHealthIndicator(KafkaMessageChannelBinder binder,
                                  org.springframework.cloud.stream.binder.kafka.properties.KafkaBinderConfigurationProperties configurationProperties)

Method Detail

health

public org.springframework.boot.actuate.health.Health health()

Specified by:

health in interface org.springframework.boot.actuate.health.HealthIndicator