rocketmq consumer接收到的MessageExt中各个字段的说明


brokerName:broker名称

queueId:记录MessageQueue编号,消息在Topic下对应的MessageQueue中被拉取

storeSize:记录消息在Broker存盘大小

queueOffset:记录在ConsumeQueue中的偏移

sysFlag:记录一些系统标志的开关状态,MessageSysFlag中定义了系统标识

bornTimestamp:消息创建时间,在Producer发送消息时设置

bornHost:记录发送改消息的producer地址

storeTimestamp:消息存储时间

storeHost:记录存储该消息的Broker地址

msgId:消息Id

commitLogOffest:记录消息在Broker中存储偏移

bodyCRC:消息内容CRC校验值

reconsumeTimes:消息重试消费次数

preparedTransactionOffset:

message

  topic:话题

  flag:网络通信层标记

  properties

    MIN_OFFSET:最小偏移

    MAX_OFFSET:最大偏移

    CONSUME_START_TIME:消费拉取时间

    UNIQ_KEY:

    CLUSTER:集群

    WAIT:

    TAGS:消息标签

body:Producer发送的实际消息内容,以字节数组(ASCII码)形式进行存储。Message消息有一定大小限制。

transactionId:事务消息相关的事务编号

 

  


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM