首页 > 解决方案 > offsetForTimes 函数在内部如何工作

问题描述

offsetForTimes函数在内部如何工作。它是根据元数据信息提取偏移量,还是实际提取 Kafka 消息以识别给定时间戳的偏移量。

当 broker/Node 上缺少offsetForTimes方法返回的偏移量时,是否存在任何情况?

标签: apache-kafkakafka-consumer-api

解决方案


推荐阅读