@Override
    public void reportFailedMsgs(FailedMsgs failedMsgs) {
        logger.info(String.format(LOG_PREFIX + "reportFailedMsgs: %s", failedMsgs));
    }
@Test
    public void testReportFailedMsgs() {
        FailedMsgs failedMsgs = new FailedMsgs();
        failedMsgs.setTopic("unit-test");
        failedMsgs.setConsumerGroup("default-consumer");
        failedMsgs.setFailedMsgsTotalRecently(2);
        defaultMonitorListener.reportFailedMsgs(failedMsgs);
    }