指定offset消费

==auto.offset.reset=earliest | latest | none== 默认是latest。
当Kafka中没有初始偏移量（消费者组第一次消费）或服务器上不再存在当前偏移量时（例如该数据已被删除），该怎么办？

  1. earliest：自动将偏移量重置为最早的偏移量，==–from-beginning==。
  2. latest（默认值）：自动将偏移量重置为最新偏移量。
  3. none：如果未找到消费者组的先前偏移量，则向消费者抛出异常。

20220423145701.png

20220423145253.png

指定时间消费

==需求==：觉得一天到现在的数据有问题，想重新消费，或者针对这个时间段的数据有新的需求，想重新跑一遍数据，获取其他信息等。或者最近几个小时的数据异常，想重新按照时间消费。

20220423151028.png