转载 ---kafka集群消费之ConsumerRecord类

2023-11-01



  • public final class ConsumerRecord <K,V> 
    extends Object
    从Kafka收到的键/值对。这包括主题名称和分区号,从中接收记录以及指向Kafka分区中记录的偏移量。
    • 构造函数摘要

      构造函数  
      构造函数和描述
      ConsumerRecord(String topic, int partition, long offset, K key, V value)
      创建从指定主题和分区接收的记录(在消息格式支持的时间戳之前和公开序列化元数据之前提供与Kafka 0.9的兼容性)。
      ConsumerRecord(String topic, int partition, long offset, long timestamp, org.apache.kafka.common.record.TimestampType timestampType, long checksum, int serializedKeySize, int serializedValueSize, K key, V value)
      创建从指定主题和分区接收的记录
    • 现场细节

      • NO_TIMESTAMP
        public static final long NO_TIMESTAMP
        也可以看看:
        常数字段值
      • NULL_SIZE
        public static final int NULL_SIZE
        也可以看看:
        常数字段值
      • NULL_CHECKSUM
        public static final int NULL_CHECKSUM
        也可以看看:
        常数字段值
    • 构造函数详细信息

      • ConsumerRecord
        public ConsumerRecord(String  topic,
                      int分区,
                      长偏移,
                      K  键,
                       V  值)
        创建从指定主题和分区接收的记录(在消息格式支持的时间戳之前和公开序列化元数据之前提供与Kafka 0.9的兼容性)。
        参数:
        topic - 收到此记录的主题
        partition - 收到此记录的主题分区
        offset - 此记录在相应Kafka分区中的偏移量
        key - 记录的密钥(如果存在)(允许为null)
        value - 记录内容
      • ConsumerRecord
        public ConsumerRecord(String  topic,
                      int分区,
                      长偏移,
                      很长的时间戳,
                      org.apache.kafka.common.record.TimestampType timestampType,
                      长校验和,
                      int serializedKeySize,
                      int serializedValueSize,
                      K  键,
                       V  值)
        创建从指定主题和分区接收的记录
        参数:
        topic - 收到此记录的主题
        partition - 收到此记录的主题分区
        offset - 此记录在相应Kafka分区中的偏移量
        timestamp - 记录的时间戳。
        timestampType - 时间戳类型
        checksum - 完整记录的校验和(CRC32)
        serializedKeySize - 序列化密钥的长度
        serializedValueSize - 序列化值的长度
        key - 记录的密钥(如果存在)(允许为null)
        value - 记录内容
    • 方法细节

      • 话题
        public  String  topic()
        收到此记录的主题
      • 划分
        public int partition()
        从中接收此记录的分区
      • 公钥  K  键()
        密钥(如果未指定密钥,则为null)
      • 公共  V  值()
        价值
      • 抵消
        公共长偏移量()
        此记录在相应Kafka分区中的位置。
      • 时间戳
        公共长时间戳()
        此记录的时间戳
      • timestampType
        public org.apache.kafka.common.record.TimestampType timestampType()
        此记录的时间戳类型
      • 校验
        公共长校验和()
        记录的校验和(CRC32)。
      • serializedKeySize
        public int serializedKeySize()
        序列化未压缩密钥的大小(以字节为单位)。如果key为null,则返回的大小为-1。
      • serializedValueSize
        public int serializedValueSize()
        序列化未压缩值的大小(以字节为单位)。如果value为null,则返回的大小为-1。
                                </div><div><div></div></div>
            <link href="https://csdnimg.cn/release/phoenix/mdeditor/markdown_views-60ecaf1f42.css" rel="stylesheet">
                                            <div class="more-toolbox">
            <div class="left-toolbox">
                <ul class="toolbox-list">
                    
                    <li class="tool-item tool-active is-like "><a href="javascript:;"><svg class="icon" aria-hidden="true">
                        <use xlink:href="#csdnc-thumbsup"></use>
                    </svg><span class="name">点赞</span>
                    <span class="count"></span>
                    </a></li>
                    <li class="tool-item tool-active is-collection "><a href="javascript:;" data-report-click="{&quot;mod&quot;:&quot;popu_824&quot;}"><svg class="icon" aria-hidden="true">
                        <use xlink:href="#icon-csdnc-Collection-G"></use>
                    </svg><span class="name">收藏</span></a></li>
                    <li class="tool-item tool-active is-share"><a href="javascript:;" data-report-click="{&quot;mod&quot;:&quot;1582594662_002&quot;}"><svg class="icon" aria-hidden="true">
                        <use xlink:href="#icon-csdnc-fenxiang"></use>
                    </svg>分享</a></li>
                    <!--打赏开始-->
                                            <!--打赏结束-->
                                            <li class="tool-item tool-more">
                        <a>
                        <svg t="1575545411852" class="icon" viewBox="0 0 1024 1024" version="1.1" xmlns="http://www.w3.org/2000/svg" p-id="5717" xmlns:xlink="http://www.w3.org/1999/xlink" width="200" height="200"><defs><style type="text/css"></style></defs><path d="M179.176 499.222m-113.245 0a113.245 113.245 0 1 0 226.49 0 113.245 113.245 0 1 0-226.49 0Z" p-id="5718"></path><path d="M509.684 499.222m-113.245 0a113.245 113.245 0 1 0 226.49 0 113.245 113.245 0 1 0-226.49 0Z" p-id="5719"></path><path d="M846.175 499.222m-113.245 0a113.245 113.245 0 1 0 226.49 0 113.245 113.245 0 1 0-226.49 0Z" p-id="5720"></path></svg>
                        </a>
                        <ul class="more-box">
                            <li class="item"><a class="article-report">文章举报</a></li>
                        </ul>
                    </li>
                                        </ul>
            </div>
                        </div>
        <div class="person-messagebox">
            <div class="left-message"><a href="https://blog.csdn.net/qq_37191690">
                <img src="https://profile.csdnimg.cn/6/2/D/3_qq_37191690" class="avatar_pic" username="qq_37191690">
                                        <img src="https://g.csdnimg.cn/static/user-reg-year/1x/3.png" class="user-years">
                                </a></div>
            <div class="middle-message">
                                    <div class="title"><span class="tit"><a href="https://blog.csdn.net/qq_37191690" data-report-click="{&quot;mod&quot;:&quot;popu_379&quot;}" target="_blank">一个小小bug</a></span>
                                        </div>
                <div class="text"><span>发布了3 篇原创文章</span> · <span>获赞 6</span> · <span>访问量 1万+</span></div>
            </div>
                            <div class="right-message">
                                        <a href="https://im.csdn.net/im/main.html?userName=qq_37191690" target="_blank" class="btn btn-sm btn-red-hollow bt-button personal-letter">私信
                    </a>
                                                        <a class="btn btn-sm  bt-button personal-watch" data-report-click="{&quot;mod&quot;:&quot;popu_379&quot;}">关注</a>
                                </div>
                        </div>
                </div>
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

转载 ---kafka集群消费之ConsumerRecord类 的相关文章

随机推荐

  • 常见的浏览器css和js兼容性问题汇总

    无论是在工作或者面试中 总会遇到关于浏览器兼容性的问题 往往会感到一头雾水不知从何说起 于是我结合一些工作经验及从网上搜集的一些资料对此做了一些汇总 希望对从事前端工作的朋友们起到一些帮助 css 1 初始化样式 由于浏览器对标签的默认支持
  • 公司刚来的00后真卷,上班还没2年,跳到我们公司起薪20k....

    都说00后躺平了 但是有一说一 该卷的还是卷 这不 前段时间我们公司来了个00后 工作都没两年 跳槽到我们公司起薪18K 都快接近我了 后来才知道人家是个卷王 从早干到晚就差搬张床到工位睡觉了 最近和他聊了一次天 原来这位小老弟家里条件不太
  • VLOG旅游类短视频如何通过抖音进行变现?运作模式有什么精髓之处?不妨了解下

    旅行日渐成为大众生活中不可或缺的一部分 大众除了利用常规拍照 拍视频的方式 来记 录旅程 volg 也走入大众视线以及短视频舞台中心 打开抖音 你能频繁刷到关于旅行 美食 学习 日常等各种主题的 vlog 博主账号 抖音 是现在年轻人每天不
  • EchartsBar 双柱状图显示数据

    需求 两组数据柱状图无缝对比 柱状上方显示数字 X轴无刻度线 背景轴线虚线指定颜色 图表代码 barChart myChart date bar1Data bar2Data myChart setOption legend 图例组件的位置
  • Cron表达式详解(配合例子)

    这里写目录标题 Cron 表达式 1 基本格式 2 一些特殊值的含义 四种 通用 特殊字符 五种有使用限制的特殊字符 L W LW 3 各个域的取值范围 Cron 表达式 在进行定时任务的创建的时候 cron是计划任务的表达式 本文意在快速
  • element table cell-style设置

    当表格中某行或者某个文字 需要单独设置 在表格table中加入 cell style cellStyle
  • 甲骨文全区登录地址

    日本东部 东京 https console ap tokyo 1 oraclecloud com https console ap tokyo 1 oraclecloud com 日本中部 大阪 https console ap osaka
  • 调试最长的一帧(第22天)

    先看看全流程 先抄一抄节点访问器NodeVisitor的工作原理 当我们执行节点的accept NodeVisitor nv 函数时 当前节点自动调哟个NodeVisitor apply方法 将自身的信息传递给节点访问器nv 由它负责执行相
  • python matplotlib.pyplot画图设置刻度

    https jingyan baidu com article 7e44095324e4062fc1e2ef76 html
  • Scheme 介绍

    最近一直在看 sicp 这本书 准备写点读书笔记 这篇当作是对 Scheme 语言的介绍 毕竟全书是用这门语言写的 下面是我对书中使用的 mit scheme 的一些理解 我没有正统学习过函数式或类 Lisp 语言 只有一些我自己在做这本书
  • Vision Transformer综述 总篇

    Vision Transformer综述 1 Transformer简介 2 Transformer组成 2 1 Self Attention Multi Head Attention 多头注意力 2 2 Transformer的其他关键概
  • Python时间序列统计模型自回归预测网络流量

    预测过程包括预测时间序列的未来值 或者通过仅基于其过去行为 自回归 对序列进行建模 或者通过使用其他外部变量来进行建模 本文档描述了如何使用机器学习和统计模型来预测访问网站的流量 使用自 2020 年 7 月 1 日起 查看网站的每日访问历
  • 五子棋AI算法简易实现(一)

    基础篇 1 胜负判定 五子棋的胜负判定的条件是其中一方下棋以后 横线 竖线 右上斜线或者右下斜线任一方向出现五子相连 即可判定获胜 此处用递归方法即可实现 var is win false var ModuleWinnerCheck che
  • 单链表的插入操作(全)

    1 在指定位序插入数据第一步 主要执行操作 查找 先查找所要插入位置的前一个元素 具体方法 根据链表的特点 每一个节点都需要一个数据域和指针域 所以只需从头节点遍历到所要插入数据的的前一个节点即可 后面的showList函数也用的这种方法第
  • SqlServer2019—解决SQL Server 无法连接127.0.0.1的问题

    1 打开SQL Server 2019配置管理器 2 SQL Servere 网络配置 启用 Named Pipes 和 TCP IP 3 修改TCP IP协议 右键选择属性 IP地址 具体如下图所示 4 重启SQL Server服务
  • C语言输出菱形

    C语言输出菱形 菱形 include
  • 栈的顺序表示

    栈底是表头 栈顶是表尾 只能在表尾插入和删除 栈的第一个元素放在下标为0的位置 虽然top指向栈顶元素 但为了方便 指向栈顶元素之上 即下一个元素的位置 stacksize栈的大小 用来表示我们当前分配的数组 我们用数组来存储栈 能存储多少
  • 聊聊什么是架构,你理解对了吗?

    什么是架构 软件有架构 建筑也有架构 它们有什么相同点和不同点 下面咱们就介绍一下 容易混淆的几个概念 一 系统与子系统 系统 泛指由一群有关联的个体组成 根据某种规则运作 能完成个别元件不能单独完成的工作的群体 它的意思是 总体 整体 或
  • C++中的单例模式

    单例模式也称为单件模式 单子模式 可能是使用最广泛的设计模式 其意图是保证一个类仅有一个实例 并提供一个访问它的全局访问点 该实例被所有程序模块共享 有很多地方需要这样的功能模块 如系统的日志输出 GUI应用必须是单鼠标 MODEM的联接需
  • 转载 ---kafka集群消费之ConsumerRecord类

    java lang Object继承 org apache kafka clients consumer ConsumerRecord