public void start(){
  if (isStarted) {
    log.info("Coordinator stream consumer already started");
    return;
  }
  log.info("Starting coordinator stream system consumer.");
  systemConsumer.start();
  isStarted=true;
}

public void start ( ) { if ( isStarted ) { log . info ( "Coordinator stream consumer already started" ) ; return ; } log . info ( "Starting coordinator stream system consumer." ) ; systemConsumer . start ( ) ; isStarted = true ; }
starts the underlying systemconsumer .
