Spring Boot: индикатор работоспособности Kafka ⇐ JAVA

[Anonymous]

У меня есть что-то вроде приведенного ниже, и оно работает хорошо, но я бы предпочел проверять работоспособность без отправки каких-либо сообщений (а не только проверки соединения с сокетом). Я знаю, что у Kafka есть что-то вроде KafkaHealthIndicator, есть ли у кого-нибудь опыт или пример его использования?
public class KafkaHealthIndicator implements HealthIndicator {
private final Logger log = LoggerFactory.getLogger(KafkaHealthIndicator.class);

private KafkaTemplate kafka;

public KafkaHealthIndicator(KafkaTemplate kafka) {
this.kafka = kafka;
}

@Override
public Health health() {
try {
kafka.send("kafka-health-indicator", "❥").get(100, TimeUnit.MILLISECONDS);
} catch (InterruptedException | ExecutionException | TimeoutException e) {
return Health.down(e).build();
}
return Health.up().build();
}
}


Подробнее здесь: https://stackoverflow.com/questions/648 ... -indicator