rocketmq console下显示消费者的trackType是UNKNOWN,并且没有消费成功

问题场景:rocket发送消息成功,但没有消费成功,消息中心消费者的trackType是UNKNOWN,并且不能resendmessage!resendmessage报错org.apache.rocketmq.client.exception.MQClientException:CODE:17DES

RocketMQ介绍及集群部署

RocketMQ具有以下特点: 1.是一个队列模型的消息中间件,具有高性能、高可靠、高实时、分布式特点。 2.Producer、Consumer、队列都可以分布式。 3.Producer向一些队列轮流发送消息,队列集合称为Topic,Consumer如果做广播消费,则一个consumer实例消费这个Topic对应的所有队列,如果做集群消费,则多个Consumer实例平均消费这个topic对应的队列集合。 4.能够保证严格的消息顺序 5.提供丰富的消息拉取模式 6.高效的订阅者水平扩展能力 7.实时的消息订阅机制 8.亿级消息堆积能力 9.较少的依赖

RocketMQ 生产者与消费者的封装

一、抽象消费类封装:packagecn.shaker.media.basic.rocketMq.consumer;importcom.google.common.collect.Maps;importlombok.extern.slf4j.Slf4j;importorg.apache.rocketm

企鹅群:39438021

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×