重置消费位点是指改变订阅者当前的消费位置。您可通过重置消费位点,按需清除堆积的或不想消费的这部分消息再开始消费,或直接跳转到某个时间点消费该时间点之后的消息(不论是否消费过该时间点之前的消息)。
前提条件
注意 在停止Consumer客户端后,需要经过
ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG
配置的时间(默认10000ms),服务端才认为Consumer真正下线。
背景信息
消息队列Kafka版支持以下重置消费位点方式:
- 消息清除:因为某种原因,订阅者不准备再继续消费Broker上堆积的消息,此时通过清除消息,可以将消费位点指定到最新的位置。
注意 堆积的消息本身并不会因此被删除,改变的只是消费位点。
- 指定时间点开始消费:将某个Consumer Group的位点重置到过去或者将来的某个时间点(该时间点以Topic的消息存储时间为准,假设为“t”)。重置过后,Consumer Group将从“t”时间点之后的消息开始消费。