A service for Kafka cluster auto healing and workload balancing