@Override
        public void onShutdown(ConnectorTaskId id) {
            taskStateTimer.changeState(State.UNASSIGNED, time.milliseconds());
            delegateListener.onShutdown(id);
        }
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