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