RocketMQ5.0中的mqadmin在创建延时消息的主题时,大家有遇到过么？怎么解决的呢？[阿里云消息队列MQ] 暂停朗读为您朗读

消息仅支持在MessageType为Delay的主题内使用，即定时消息只能发送至类型为定时消息的主题中，发送的消息的类型必须和主题的类型一致。

https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/developer-reference/scheduled-and-delayed-messages?spm=a2c4g.11186623.0.i27#concept-2217704

使用示例
和普通消息相比，定时消费发送时，必须设置定时触发的目标时间戳。

以Java语言为例，使用定时消息示例参考如下：

        MessageBuilder messageBuilder = new MessageBuilder();        //以下示例表示：延迟时间为10分钟之后的Unix时间戳。        Long deliverTimeStamp = System.currentTimeMillis() + 10L * 60 * 1000;        Message message = messageBuilder.setTopic("topic")                //设置消息索引键，可根据关键字精确查找某条消息。                .setKeys("messageKey")                //设置消息Tag，用于消费端根据指定Tag过滤消息。                .setTag("messageTag")                .setDeliveryTimestamp(deliverTimeStamp)                //消息体                .setBody("messageBody".getBytes())                .build();        try {            //发送消息，需要关注发送结果，并捕获失败等异常。            SendReceipt sendReceipt = producer.send(message);            System.out.println(sendReceipt.getMessageId());        } catch (ClientException e) {            e.printStackTrace();        }        //消费示例一：使用PushConsumer消费定时消息，只需要在消费监听器处理即可。        MessageListener messageListener = new MessageListener() {            @Override            public ConsumeResult consume(MessageView messageView) {                System.out.println(messageView.getDeliveryTimestamp());                //根据消费结果返回状态。                return ConsumeResult.SUCCESS;            }        };        //消费示例二：使用SimpleConsumer消费定时消息，主动获取消息进行消费处理并提交消费结果。        List messageViewList = null;        try {            messageViewList = simpleConsumer.receive(10, Duration.ofSeconds(30));            messageViewList.forEach(messageView -> {                System.out.println(messageView);                //消费处理完成后，需要主动调用ACK提交消费结果。                try {                    simpleConsumer.ack(messageView);                } catch (ClientException e) {                    e.printStackTrace();                }            });        } catch (ClientException e) {            //如果遇到系统流控等原因造成拉取失败，需要重新发起获取消息请求。            e.printStackTrace();        }