private int pollCount() {
        return (int) MockitoUtils.countInvocations(sourceTask, "poll");
    }
@return how many times the source task was {@link SourceTask#poll() polled}
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTaskTest.java