private void startProcess() {
      int count = messagesInFlight.incrementAndGet();
      taskMetrics.messagesInFlight().set(count);
    }
Returns the next operation by this taskWorker
samza-core/src/main/java/org/apache/samza/container/RunLoop.java