public void tryResetPopRetryTopic(final List<MessageExt> msgs, String consumerGroup) {
        String popRetryPrefix = MixAll.RETRY_GROUP_TOPIC_PREFIX + consumerGroup + "_";
        for (MessageExt msg : msgs) {
            if (msg.getTopic().startsWith(popRetryPrefix)) {
                String normalTopic = KeyBuilder.parseNormalTopic(msg.getTopic(), consumerGroup);
                if (normalTopic != null && !normalTopic.isEmpty()) {
                    msg.setTopic(normalTopic);
                }
            }
        }
    }
@Test
    public void testTryResetPopRetryTopic() {
        TopicRouteData topicRouteData = new TopicRouteData();
        topicRouteData.getBrokerDatas().add(createBrokerData());
        MessageExt messageExt = createMessageExt();
        List<MessageExt> msgs = new ArrayList<>();
        messageExt.setTopic(MixAll.RETRY_GROUP_TOPIC_PREFIX + defaultGroup + "_" + defaultTopic);
        msgs.add(messageExt);
        defaultMQPushConsumerImpl.tryResetPopRetryTopic(msgs, defaultGroup);
        assertEquals(defaultTopic, msgs.get(0).getTopic());
    }