public static void require(boolean requirement, String errorMessage) {
        if (!requirement)
            throw new IllegalArgumentException(errorMessage);
    }
Checks requirement. Throw {@link IllegalArgumentException} if {@code requirement} failed.
@param requirement Requirement to check.
@param errorMessage String to include in the failure message
clients/src/main/java/org/apache/kafka/common/utils/Utils.java