public static void setFieldValue(Object obj, String fieldName, Object value) throws Exception {
        Field field = obj.getClass().getDeclaredField(fieldName);
        field.setAccessible(true);
        field.set(obj, value);
    }
Assert that a future raises an expected exception cause type. Return the exception cause
if the assertion succeeds; otherwise raise AssertionError.

@param future The future to await
@param exceptionCauseClass Class of the expected exception cause
@param <T> Exception cause type parameter
@return The caught exception cause
clients/src/test/java/org/apache/kafka/test/TestUtils.java