ClusterHealthCheck checks health of the kafka cluster.

CreateLivenessPod creates the kafka liveness pod.

DisplayKafkaBroker displays the kafka broker info.

LivenessCleanup deletes the kafka liveness pod.

LivenessStream generates kafka liveness pod, which continuously validate the liveness of kafka brokers and derive the kafka topic leader(candidate for the deletion).