@Override
    protected RocketMQLogCollectClient getLogConsumeClient() {
        return LoggingRocketMQPluginDataHandler.getRocketMqLogCollectClient();
    }
@Test
    public void testGetLogConsumeClient() {
        LogConsumeClient logConsumeClient = new RocketMQLogCollector().getLogConsumeClient();
        Assertions.assertEquals(RocketMQLogCollectClient.class, logConsumeClient.getClass());
    }