文章目录
- 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