@Override
    protected KafkaLogCollectClient getLogConsumeClient() {
        return LoggingKafkaPluginDataHandler.getKafkaLogCollectClient();
    }
@Test
    public void testGetLogConsumeClient() {
        LogConsumeClient logConsumeClient = new KafkaLogCollector().getLogConsumeClient();
        Assertions.assertEquals(KafkaLogCollectClient.class, logConsumeClient.getClass());
    }