public void recordState(TargetState state) {
            switch (state) {
                case STARTED:
                    taskStateTimer.changeState(State.RUNNING, time.milliseconds());
                    break;
                case PAUSED:
                    taskStateTimer.changeState(State.PAUSED, time.milliseconds());
                    break;
                default:
                    break;
            }
        }
Record that a batch of records has been processed.

@param size the number of records in the batch
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java