@Test
    public void testSuspendFailWhenNotAck() {
        Pair<String, String> groupStream = saveSource("group1,group3");
        bindGroup(true, "group1");

        agent.pullTask();
        agent.pullTask(); // report last success status

        // mismatch
        bindGroup(false, "group1");
        agent.pullTask();

        // suspend
        try {
            suspendSource(groupStream.getLeft(), groupStream.getRight());
        } catch (BusinessException e) {
            Assertions.assertTrue(e.getMessage().contains("is not allowed to stop"));
        }
    }
Test suspend group when frozen task without ack.
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/AgentServiceTest.java