code: public void start() throws InterruptedException, ExecutionException {
          Future<?> task = es.submit(handlePartitionChange);
          task.get();
      }
docs: Start monitoring the leaders. This is a blocking operation.
  
  @throws InterruptedException
  @throws ExecutionException