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:事务消息相关的事务编号

      

  • 相关阅读:
    C++ 11 lambda
    Win环境下的文件读写
    基于 Jenkins+Docker+Git 的CI流程初探
    python切片操作
    k8s 集群中的etcd故障解决
    Git 版本控制管理(二)
    Git 版本控制管理(一)
    Harbor 企业级镜像仓库搭建
    docker 数据管理
    docker 网络的几种模式
  • 原文地址:https://www.cnblogs.com/pass-ion/p/13440145.html
Copyright © 2011-2022 走看看