org.springframework.cloud.stream.binder.kafka

Class KafkaBinderHealthIndicator

java.lang.Object

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

public class KafkaBinderHealthIndicator
extends Object

Health indicator for Kafka.

Author:

Ilayaperumal Gopinathan, Marius Bogoevici, Henryk Konsek, Gary Russell, Laur Aliste

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
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 Health health()