module Kafkat::ClusterRestart