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

关键字 kafkaConsumer.seek(topicPartition,100); // 指定offset 实现代码 ...

指定offset: 指定分区： 原文强参考：https://www.cnblogs.com/shouke/p/10463377.html ...

重复这个实验的注意事项 1.首先要知道自己topic ,分区数,checkpoint的文件夹 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor ...

需要依赖包，并放到flink/lib目录中： 下载地址： https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#jdbc-connector ...

https://blog.csdn.net/menxin_job/article/details/86712973?utm_medium=distribute.pc_relevant_t0.none- ...

转自： https://www.jianshu.com/p/932663e9a226 ...

Kafka 提供了 3 种提交 offset 的方式 自动提交 复制 1234 // 自动提交,默认trueprops.put("enable.auto.commit", "true");// 设置自动每1s提交一次props.put ...