-package de.juplo.kafka;
-
-import lombok.RequiredArgsConstructor;
-import org.springframework.boot.actuate.health.Health;
-import org.springframework.boot.actuate.health.HealthIndicator;
-import org.springframework.kafka.config.KafkaListenerEndpointRegistry;
-
-
-@RequiredArgsConstructor
-public class ApplicationHealthIndicator implements HealthIndicator
-{
- private final String id;
- private final KafkaListenerEndpointRegistry registry;
-
-
- @Override
- public Health health()
- {
- return registry.getListenerContainer(id).isRunning()
- ? Health.up().build()
- : Health.down().build();
- }
-}