1.概述
首先参考文章：【Flink】Flink 1.14.0 全新的 Kafka Connector
Kafka Source 能够通过指定 OffsetsInitializer来消费从不同偏移量开始的消息。内置的初始值设定项包括：
KafkaSource.builder()
// Start from committed offset of the consuming group, without reset strategy
.setStartingOffsets转载：https://blog.csdn.net/qq_21383435/article/details/125360383
查看评论