文章目录

  • 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