问我可以从消费者处读取特定的kafka偏移量吗
EN

Stack Overflow用户

提问于 2019-09-04 13:52:03

回答 1查看 166关注 0票数 0

我正在尝试从特定的偏移量读取并写入HDFS

我尝试从特定的分区，它是工作的，但偏移不工作

我需要获取特定偏移量的值，例如..latest offset为5000，但我只需要读取offset 3000，而不是从3000到5000

发布于 2019-09-04 14:31:54

您可以使用消费者的seek(TopicPartition，long)方法，然后只处理第一个记录，然后中断循环。

如果你需要额外的帮助，请告诉我。

有关方法的更多信息，请单击here

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/57782228

复制

相似问题

问我可以从消费者处读取特定的kafka偏移量吗EN