public State state() {
            return taskStateTimer.currentState();
        }
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