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<String, Long> consumer;
17 public Health health()
19 return consumer.isRunning() ? Health.up().build() : Health.down().build();