I'm trying to write a health check for kafka, that would run periodically, check connectivity and