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