特牛网址导航

Kafka3.0 Offset 消费方式_offset消费-CSDN博客

网友收藏
文章浏览阅读421次。默认是 latest。当 Kafka 中没有初始偏移量(消费者组第一次消费)或服务器上不再存在当前偏移量时(例如该数据已被删除),该怎么办?(1)earliest:自动将偏移量重置为最早的偏移量,–from-beginning。(2)latest(默认值):自动将偏移量重置为最新偏移量。(3)none:如果未找到消费者组的先前偏移量,则向消费者抛出异常。需求:在生产环境中,会遇到最近消费的几个小时数据异常,想重新按照时间消费。例如要求按照时间消费前一天的数据,怎么处理?代码如下:..._offset消费
标签:offset消费