位置:公共长位置(TopicPartition分区)获取将被获取的下一个记录的偏移量(如果存在带有该偏移量的记录)。
提交:获取给定分区的最后提交偏移量(无论提交是由此进程还是其他进程进行的)。在发生故障时，此偏移量将用作使用者的位置。此调用将阻止进行远程调用，以从服务器获取最新提交的偏移量。这是否意味着如果consumer.poll()获取50条消息，从偏移量101到150，并且使用者有手动偏移提
浏览 0提问于2017-11-29得票数 13
回答已采纳
我正在尝试使用re.search()获取匹配的偏移量。
该站点解释了如何获取匹配组件相对于比赛开始的偏移量，但没有说明如何在"haystack“字符串中获取匹配本身的偏移量。
浏览 0提问于2013-04-07得票数 5
回答已采纳
我正在尝试获取某个消费者组的特定偏移量的提交时间。我检查了管理客户端应用程序接口。listConsumerGroupOffsets应用程序接口只返回偏移量信息。如何获取该特定消费者组的偏移量的时间戳(提交时间戳)？
浏览 22提问于2019-06-04得票数 0
4回答
Mysql:我需要在查询中获取项的偏移量。一个查询就可以了吗？编辑： select * from order_by updated_at偏移量(在这里我需要在这个查询中获得图像
浏览 4提问于2010-04-02得票数 1
回答已采纳
如何获取当前UTC偏移量(与时区相同，但仅获取当前时刻的UTC偏移量)？
我需要一个像"+02:00“这样的答案。
浏览 6提问于2010-10-04得票数 5
回答已采纳
据我所知，它依靠HDFS检查点目录来存储偏移量，并保证“只传递一次”消息。如果要将Kafka源的偏移量存储到事务型DB中，如何从结构化流批处理中获取偏移量？rdd.asInstanceOf[HasOffsetRanges].offsetRanges
但是使用新的流API，我有一
浏览 1提问于2017-09-11得票数 28
回答已采纳
是否有更有效/更简单的方法来使用最新的Java客户端2.4API获取主题/分区的大小/最新偏移量？然后，通过将消费者组的偏移量与主题的大小进行比较，计算消费者群体的滞后.据我所知，获取这些信息的通常方法是：
使用consumer.seekToEnd(...
浏览 2提问于2020-02-05得票数 3
回答已采纳
我使用getTimezoneOffset()来获取给定日期对象的偏移量(分钟)。可以使用javascript获取城市或国家的时区偏移量吗？
浏览 4提问于2016-05-03得票数 7
我正在尝试从浏览器中的时区偏移量中查找时区字符串，例如‘Europe/柏林’。我使用new Date().getTimezoneOffset();在客户端获取时区偏移量。如何使用此偏移量获取时区字符串Europe/Berlin，这是moment().tz('Europe/Berlin')期望用于转换的格式类型。
提前感谢！
浏览 3提问于2014-12-22得票数 0
3回答
使用时区偏移PHP
、、、、
我的注册页面上有JavaScript代码，它在用户登录时获取时区偏移量，并将其设置为数据库中的时区偏移量变量，如下面的"-06:00,1"所示。如果遵守夏令时，则设置1。我的数据库设置为英国时间或GMT +0:00，我需要从数据库中获取时间，并使用用户的时区偏移量来获取他们所在位置的正确时区。我试过了：上面的代码可以工作
浏览 5提问于2013-07-13得票数 0
1回答
我使用var offset = new Date().getTimezoneOffset()获取用户当前的时区偏移量。
但是，我怎样才能得到将来任何时间的时区偏移量？这是必需的，因为当DST启用/禁用时，时区偏移量是不同的，所以我不能为以后的时间假设相同的偏移量。
浏览 2提问于2012-08-24得票数 0
8回答
在MySQL中有没有办法计算任何时区的偏移量？例如，获取时区Asia/calcutta中的本地时间。我想要做的是计算这个时区的偏移量，并将这个偏移量与GMT相加，以获得本地时间。
浏览 7提问于2009-04-30得票数 16
回答已采纳
我在着色器中有一个shared布局统一块：{};当我尝试使用glGetUniformIndices获取test[3]的索引时，它将返回与test[0]的索引相同的数目。因此，我不能使用glGetActiveUniformsiv来获取test[3]索引的偏移量。(请注意，我不想使用布局std140。)
浏览 2提问于2021-04-28得票数 0
回答已采纳
但是我不想自动提交偏移量，因为一旦从Kafka获取记录，我就有一些处理逻辑。
从Kafka获取记录之后，如果处理成功，那么我只想提交偏移量，否则它应该再次从相同的偏移量读取。
浏览 2提问于2019-10-22得票数 3
我可以使用偏移量和限制函数，但是如何从上一次获取的行的偏移量开始获取下一行。假设我有一个包含50000项的数据集，并且希望在第1页中显示50项，所以我只想获取50项，当我单击下一页时，它应该获取并显示下一页中的50项。
浏览 0提问于2018-06-08得票数 0
回答已采纳
2回答
获取字节偏移量作为键应该很容易，因为这就是TextInputFormat所做的。我怎么才能得到这个？我知道你可以使用环境变量'map_input_start‘自己计算字节偏移量，但这会带来问题，我想用一种简单得多的方法来获取偏移量作为键。
浏览 2提问于2012-07-11得票数 0
我想使用Pytz根据给定的UTC偏移量转换timestamp对象(从模型中获取)。在将其呈现到模板之前，当我打印timestamp对象时，它使用以下格式：我使用下面的代码行来获取偏移量：上面的偏移量将给+0530 .Now我想要用这个偏移量
浏览 7提问于2012-05-29得票数 1
回答已采纳
我试图通过使用获取和存储卡夫卡中特定消息的偏移量。查看Spark文档可以很简单地获得每个分区的范围偏移量，但我需要的是在对队列进行全面扫描之后，为每个主题的消息存储开始偏移量。
浏览 5提问于2016-06-01得票数 7
回答已采纳
1回答
这里是 for public ConsumerRecords<K,V> poll(long timeout)
获取使用订阅/分配API之一指定的主题或分区的数据。在每次投票中，使用者将尝试使用最后消耗的偏移量作为起始偏移量并按顺序获取。最后消耗的偏移量可以通过查找(TopicPartition，long)手动设置，也可以自动设置为已订阅的分区列表的最后提交偏移量。我的问题是谁(经纪人或消费者或动物园)负责维护偏移量和它的存储地点(内存或光盘)？如
浏览 0提问于2017-06-18得票数 6
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
