@Override
        public void run() {
            channelManager.shutdown();
        }
Handles shutdown of the {@link AssignmentsManager}.
server/src/main/java/org/apache/kafka/server/AssignmentsManager.java