public void expectedRecords(int expected) {
        expectedRecords = expected;
        recordsRemainingLatch = new CountDownLatch(expected);
    }
Set the number of expected records for this connector.

@param expected number of records
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorHandle.java