Package org.springframework.cloud.stream.binder.kafka

Class KafkaBinderHealthIndicator

java.lang.Object
org.springframework.boot.health.contributor.AbstractHealthIndicator
org.springframework.cloud.stream.binder.kafka.common.AbstractKafkaBinderHealthIndicator
org.springframework.cloud.stream.binder.kafka.KafkaBinderHealthIndicator
All Implemented Interfaces:
org.springframework.beans.factory.DisposableBean, org.springframework.boot.health.contributor.HealthContributor, org.springframework.boot.health.contributor.HealthIndicator
public class KafkaBinderHealthIndicator extends org.springframework.cloud.stream.binder.kafka.common.AbstractKafkaBinderHealthIndicator
Health indicator for Kafka.
Author:
Ilayaperumal Gopinathan, Marius Bogoevici, Henryk Konsek, Gary Russell, Laur Aliste, Soby Chacko, Vladislav Fefelov, Chukwubuikem Ume-Ugwa, Taras Danylchuk

  • Field Summary

    Fields inherited from class org.springframework.cloud.stream.binder.kafka.common.AbstractKafkaBinderHealthIndicator

    considerDownWhenAnyPartitionHasNoLeader, metadataConsumer, timeout

  • Constructor Summary

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

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.springframework.boot.health.contributor.Health
    buildBinderSpecificHealthDetails()
     
    protected ExecutorService
    createHealthBinderExecutorService()
     
    protected Map<String,org.springframework.cloud.stream.binder.kafka.common.TopicInformation>
    getTopicsInUse()
     

    Methods inherited from class org.springframework.cloud.stream.binder.kafka.common.AbstractKafkaBinderHealthIndicator

    destroy, doHealthCheck, safelyBuildTopicsHealth, setConsiderDownWhenAnyPartitionHasNoLeader, setTimeout

    Methods inherited from class org.springframework.boot.health.contributor.AbstractHealthIndicator

    health

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.springframework.boot.health.contributor.HealthIndicator

    health

  • Constructor Details

    • KafkaBinderHealthIndicator

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

  • Method Details

    • createHealthBinderExecutorService

      protected ExecutorService createHealthBinderExecutorService()
      Specified by:
      createHealthBinderExecutorService in class org.springframework.cloud.stream.binder.kafka.common.AbstractKafkaBinderHealthIndicator

    • getTopicsInUse

      protected Map<String,org.springframework.cloud.stream.binder.kafka.common.TopicInformation> getTopicsInUse()
      Specified by:
      getTopicsInUse in class org.springframework.cloud.stream.binder.kafka.common.AbstractKafkaBinderHealthIndicator

    • buildBinderSpecificHealthDetails

      protected org.springframework.boot.health.contributor.Health buildBinderSpecificHealthDetails()
      Specified by:
      buildBinderSpecificHealthDetails in class org.springframework.cloud.stream.binder.kafka.common.AbstractKafkaBinderHealthIndicator