如何在springboot中实现kafka指定offset消费,你知道么？

前言

kafka消费过程难免会遇到需要重新消费的场景，例如我们消费到kafka数据之后需要进行存库操作，若某一时刻数据库down了，导致kafka消费的数据无法入库，为了弥补数据库down期间的数据损失，有一种做法我们可以指定kafka消费者的offset到之前某一时间的数值，然后重新进行消费。

这里大家可以关注一下我的个人专栏《Java 进阶集中营》，每天会给大家即时分享一个新的java技术资讯，有的java技术内容，也欢迎分享在我的专栏。

首先创建kafka消费服务#

Copy@Service
@Slf4j
//实现CommandLineRunner接口，在springboot启动时自动运行其run方法。
public class TspLogbookAnalysisService implements CommandLineRunner {
    @Override
    public void run(String... args) {
        //do something
    }
}