public void record() {
        if (recordsRemainingLatch != null) {
            recordsRemainingLatch.countDown();
        }
    }
Record a message arrival at the connector.
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorHandle.java