1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import org.springframework.boot.actuate.health.Health;
5 import org.springframework.boot.actuate.health.HealthIndicator;
6 import org.springframework.kafka.config.KafkaListenerEndpointRegistry;
9 @RequiredArgsConstructor
10 public class ApplicationHealthIndicator implements HealthIndicator
12 private final String id;
13 private final KafkaListenerEndpointRegistry registry;
17 public Health health()
19 return registry.getListenerContainer(id).isRunning()
21 : Health.down().build();