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

      

  • 相关阅读:
    快速认识ELK中的L
    HBase启动和停止命令
    Kafka 快速起步(作者:杜亦舒)
    Kafka 消息存储及检索(作者:杜亦舒)
    HBase集群搭建
    Kafka消息保证不丢失和重复消费问题
    Kafka文件的存储机制
    Kafka的配置文件详细描述
    kafka常用操作命令
    BZOJ1769 : [Ceoi2009]tri
  • 原文地址:https://www.cnblogs.com/pass-ion/p/13440145.html
Copyright © 2011-2022 走看看