class Kafkat::ClusterRestart::UnknownStateError