1，为什么要：
当需要实现重复消费历史数据的时候，就需要重设消费者组位移

2，为什么能：
    A ：Kafka和传统的消费引擎在设计上有很大区别，其中一个比较显著的区别是：Kafka的消息费者读取消息是可以重演的（replayable）
    B ：如RabbitMQ或ActiveMQ这样的传统消息中间件，他们处理和响应消息的方式是破坏性的（destructive）,一旦消息被成功处理，就会被从Broker上删除。
    C ：Kafka，由于它是基于日志结构（log-based）的消息引擎，消费者在消费消息时，仅仅是从磁盘文件上读取数据，是只读操作，因此消费者不会删除消息数据。同时，由于位移数据是由消费者控制的，因此他能够很容易的修改位移值，实现重复消费历史数据的功能。

3，重设位移策略
    A ：位移维度：根据位移值来重设。直接把消费者的位移值重设成我们给定的值。
    B ：时间维度：可以给定一个时间，让消费者吧位移调整成大于该时间的最小位移；亦可以给出一段时间间隔，如30分钟，然后让消费者直接将位移调回30分钟之前的位移值。
七种策略：
（1）Earliest：将位移调整到主题当前最早位移处。可以实现重新消费主题的所有消息
（2）Latest：把位移重设成最新末端位移。可以跳过所有历史消息，从最新消息开始消费
（3）Current：将位移调整成消费者当前提交的最新位移，可以实现把位移重设到消费者重启时的位置。
（4）Specified-Offset：把位移值调整到指定的位移处。这可以实现跳过某条错误信息，避免造成消费阻塞。
（5）Shift-By-N：相对于当前位值的位移值，可以向前或向后，跳出一段距离。
（6）DataTime：指定一个时间，然后将位移重置到该时间之后的最早位移处。
（7）Duration：给定相对时间间隔，让位移调整到距离当前给定时间间隔的位移处。

4 重设的方法
    A ：通过消费者API来实现
    B ：通过Kafka-consumer-groups命令行脚本来实现

    消费者API注意事项：
    （1）：要创建消费者程序，要禁止自动提交位移
    （2）：组ID要设置成要重设的消费者组的组ID
    （3）：调用seekToBeginning方法时，要一次性构造主题的所有分区对象
    （4）：最重要的是，一定要调用带长整形的poll方法，而不调用consumer.poll(Duration.ofSecond(0))。
    （5）：要实现DateTime策略：需要借助KafkaConsumer.offsetsForTimes方法。
    
    总之：使用Java API的方式来实现重设策略的主要入口方法，就是seek方法。

    命令行方式注意事项：
    （1）bin/kafka-consumer-groups.sh --bootstrap-server kafka-host:port --group test-group --reset-offsets --all-topics --to-earliest –execute

打卡，此节讲解了

1：为啥需要重设消费者组位移？

当需要实现重复消费历史数据的时候，就需要重设消费者组位移。


2：重设消费者组位移的实现？

有两种方式七种策略(两种维度：位移和时间)

两种方式：操作API、操作kafka命令

七种策略：

2-1：Earliest 策略——表示将位移调整到主题当前最早位移处。

2-2：Latest 策略——表示把位移重设成最新末端位移。

2-3：Current 策略——表示将位移调整成消费者当前提交的最新位移。

2-4：Specified-Offset 策略——则是比较通用的策略，表示消费者把位移值调整到你指定的位移处。这个策略的典型使用场景是，消费者程序在处理某条错误消息时，你可以手动地“跳过”此消息的处理。

2-5： Shift-By-N 策略——指定的是位移的相对数值，即你给出要跳过的一段消息的距离即可。这里的“跳”是双向的，你既可以向前“跳”，也可以向后“跳”。

2-6：DateTime策略—— 允许你指定一个时间，然后将位移重置到该时间之后的最早位移处。

2-7：Duration 策略——则是指给定相对的时间间隔，然后将位移调整到距离当前给定时间间隔的位移处，具体格式是 PnDTnHnMnS。