Implement a Kafka health indicator. Something similar to `org.springframework.boot.actuate.amqp.RabbitHealthIndicator`.