@Override
    protected PulsarLogCollectClient getLogConsumeClient() {
        return LoggingPulsarPluginDataHandler.getPulsarLogCollectClient();
    }
@Test
    public void testGetLogConsumeClient() {
        LogConsumeClient logConsumeClient = new PulsarLogCollector().getLogConsumeClient();
        Assertions.assertEquals(PulsarLogCollectClient.class, logConsumeClient.getClass());
    }