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.stereotype.Component;
10 @RequiredArgsConstructor
11 public class ApplicationHealthIndicator implements HealthIndicator
13 private final EndlessConsumer consumer;
17 public Health health()
19 return consumer.running()
21 : Health.down().build();