@Ignore
    public void localTest() throws Exception {
        RestTemplate restTemplate = new RestTemplate();
        PulsarClusterInfo pulsarClusterInfo = new PulsarClusterInfo();
        pulsarClusterInfo.setAdminUrl("http://127.0.0.1:8080");
        String topic = "public/test_pulsar_group/test_pulsar_stream";

        ResponseEntity<byte[]> pulsarMessage =
                PulsarUtils.examineMessage(restTemplate, pulsarClusterInfo,
                        topic, "latest", 1);
        List<PulsarMessageInfo> result = PulsarUtils.getMessagesFromHttpResponse(pulsarMessage, topic);
        System.out.println(result);
    }
The case only supports local testing.

@throws Exception
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/queue/PulsarUtilsTest.java