zoukankan      html  css  js  c++  java
  • 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:事务消息相关的事务编号

      

  • 相关阅读:
    Java入门第二阶段总结
    POj3017 dp+单调队列优化
    CH5701 开车旅行(倍增dp+set)
    dp优化---四边形不等式与决策单调性
    CH5E07 划分大理石(背包dp+二进制拆分)
    POJ1185 炮兵阵地(状压dp)
    CH5501 环路运输(单调栈)
    poj3585 Accumulation Degree(换根dp)
    CH5105 Cookies (线性dp)
    反射
  • 原文地址:https://www.cnblogs.com/pass-ion/p/13440145.html
Copyright © 2011-2022 走看看