文章目录

• 1.概述
• 2.测试
• 3.源码

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