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, Henryk Konsek, Gary Russell

Constructor Summary

Constructors

Constructor and Description
KafkaBinderHealthIndicator(KafkaMessageChannelBinder binder, org.springframework.kafka.core.ConsumerFactory<?,?> consumerFactory)

Method Summary

Modifier and Type	Method and Description
org.springframework.boot.actuate.health.Health	health()
void	setTimeout(int timeout) Set the timeout in seconds to retrieve health information.

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.kafka.core.ConsumerFactory<?,?> consumerFactory)

Method Detail

setTimeout

public void setTimeout(int timeout)

Set the timeout in seconds to retrieve health information.

Parameters:

timeout - the timeout - default 60.

health

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

Specified by:

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