private void verifyEmptyConnectorOffsets(String connectorName) throws InterruptedException {
        waitForCondition(() -> {
            ConnectorOffsets offsets = connect.connectorOffsets(connectorName);
            return offsets.offsets().isEmpty();
        }, OFFSET_READ_TIMEOUT_MS, "Connector offsets should be empty after resetting offsets");
    }
Verify whether the <strong><em>GET /connectors/{connector}/offsets</em></strong> returns empty offsets for a source
or sink connector whose offsets have been reset via the <strong><em>DELETE /connectors/{connector}/offsets</em></strong>
REST API

@param connectorName the name of the connector whose offsets are to be verified
@throws InterruptedException if the thread is interrupted while waiting for the offsets to be empty
connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java